2026 Q2 Updates - Neaera Fork

.github/workflows/artifact-publish.yml

@@ -7,6 +7,9 @@ on:
 jobs:
   build:
     runs-on: ubuntu-latest
+    permissions:
+      contents: read
+      packages: write
 
     steps:
     - name: Checkout code (with submodules)

README.md

@@ -444,6 +444,23 @@ In order to utilize Confluent Cloud:
 
 #### Note
 
+### Port Mapped Receiver Configuration
+Many production deployments may not send intersection data directly from an RSU unit. This often happens if another device is responsible for generating MAP / SPaT messages or if a proxy or load balancer is used between an RSU unit and the ODE. To handle these edge cases the ODE has a configurable port-mapped receiver which can be used for receiving data on a variety of ports. The intent of this feature is to allow the ODE to continue to identify different source RSU units based upon the port the data is forwarded on. 
+
+To use port-mapped ingest, add an entry similar to the below to the application.yaml file. The entry below creates a BSM receiver which listens on port 1234. Any BSM data received on port 1234 will be marked as having been received from the IP 1.2.3.4.
+
+```
+port-mapped-ingest:
+  sources:
+    - intersectipon-name: "Name"
+      intersection-id: 1234
+      origin-ip: 1.2.3.4
+      port: 1234
+      type: BSM
+```
+
+Please note, ports added here are not automatically opened in the host docker container. Any port added here should separately be added to the running docker container.
+
 This has only been tested with Confluent Cloud but technically all SASL authenticated Kafka brokers can be reached using this method.
 
 [Back to top](#table-of-contents)
@@ -464,6 +481,8 @@ The configuration that defines this is in the jpo-utils submodule [here](jpo-uti
 
 For further documentation on configuring the MongoDB Kafka Connect image refer [to this readme](jpo-utils/README.md).
 
+
+
 ## Note
 
 Kafka connect is being used for MongoDB in this implementation but it can interact with many types of databases, here is further documentation for [kafka connect](https://docs.confluent.io/platform/current/connect/index.html)

docker-compose.yml

@@ -64,6 +64,7 @@ services:
       ODE_ROCKSDB_BLOCK_SIZE: ${ODE_ROCKSDB_BLOCK_SIZE}
       ODE_ROCKSDB_N_MEMTABLES: ${ODE_ROCKSDB_N_MEMTABLES}
       ODE_ROCKSDB_MEMTABLE_SIZE: ${ODE_ROCKSDB_MEMTABLE_SIZE}
+      ODE_KAFKA_LISTENER_CONCURRENCY: ${ODE_KAFKA_LISTENER_CONCURRENCY}
     depends_on:
       kafka:
         condition: service_healthy
@@ -104,6 +105,7 @@ services:
       ACM_LOG_TO_CONSOLE: ${ADM_LOG_TO_CONSOLE}
       ACM_LOG_TO_FILE: ${ADM_LOG_TO_FILE}
       ACM_LOG_LEVEL: ${ADM_LOG_LEVEL}
+      ACM_NUMBER_OF_PROCESSES: ${ADM_NUMBER_OF_PROCESSES:-1}
     depends_on:
       kafka:
         condition: service_healthy
@@ -137,6 +139,7 @@ services:
       ACM_LOG_TO_CONSOLE: ${AEM_LOG_TO_CONSOLE}
       ACM_LOG_TO_FILE: ${AEM_LOG_TO_FILE}
       ACM_LOG_LEVEL: ${AEM_LOG_LEVEL}
+      ACM_NUMBER_OF_PROCESSES: ${AEM_NUMBER_OF_PROCESSES:-1}
     depends_on:
       kafka:
         condition: service_healthy

docs/Release_notes.md

@@ -1,6 +1,19 @@
 JPO-ODE Release Notes
 ----------------------------
 
+Version 6.0.0, released May 2026
+----------------------------------------
+### **Summary**
+This release expands support for existing jpo-ode functionality and improves flexibility in deployment and data handling. JSON schemas are now bundled within the jpo-asn-pojos submodule, enabling offline usage without external dependencies. Additionally, a receiving port remapping configuration has been introduced to better identify traffic sources that may not originate from an RSU. This release also includes several minor fixes.
+
+Enhancements in this release:
+- [ASN Hex 1609.2 Signature Retention (ITSA)](https://github.com/usdot-jpo-ode/jpo-ode/pull/596)
+- [Submodule update to provide JSON schemas in resources for offline availability](https://github.com/neaeraconsulting/jpo-ode/pull/1)
+- [Port remap receiver](https://github.com/neaeraconsulting/jpo-ode/pull/2)
+- [Configurable kafka concurrency](https://github.com/neaeraconsulting/jpo-ode/pull/3)
+- [Docker shared Kafka fix](https://github.com/neaeraconsulting/jpo-ode/pull/9)
+- [Add env vars for number of ACM processes, update test process](https://github.com/neaeraconsulting/jpo-ode/pull/7)
+
 Version 5.1.0, released October 2025
 ----------------------------------------
 ### **Summary**

docs/compatibility.md

@@ -3,6 +3,7 @@ This table serves as a guide, suggesting which versions of individual submodules
 
 | [ODE (this project)](https://github.com/usdot-jpo-ode/jpo-ode/releases) | [ACM](https://github.com/usdot-jpo-ode/asn1_codec/releases) | [PPM](https://github.com/usdot-jpo-ode/jpo-cvdp/releases) | [SEC](https://github.com/usdot-jpo-ode/jpo-security-svcs/releases) | [SDWD](https://github.com/usdot-jpo-ode/jpo-sdw-depositor/releases) | [S3D](https://github.com/usdot-jpo-ode/jpo-s3-deposit/releases) | [GJConverter](https://github.com/usdot-jpo-ode/jpo-geojsonconverter/releases) | [CMonitor](https://github.com/usdot-jpo-ode/jpo-conflictmonitor/releases) | [CVisualizer](https://github.com/usdot-jpo-ode/jpo-conflictvisualizer/releases) | [CVManager](https://github.com/usdot-jpo-ode/jpo-cvmanager/releases) | [MEC](https://github.com/usdot-jpo-ode/jpo-mec-deposit/releases) |
 |-------|-------|-------|-------|-------|-------|-------|-------|-------|-------|-------|
+| 6.0.0 | 3.3.0 | 1.6.0 | 1.7.0 | 1.10.0 | 1.7.1 | 3.3.0 | 3.2.0 |  N/A  | 2.1.0 | 1.1.0 |
 | 5.1.0 | 3.2.0 | 1.6.0 | 1.7.0 | 1.10.0 | 1.7.1 | 3.2.0 | 3.1.0 |  N/A  | 2.0.0 | 1.0.0 |
 | 4.1.2 | 3.1.0 | 1.5.0 | 1.6.0 | 1.9.1 | 1.7.1 | 2.1.0 | 2.1.0 | 1.5.0 | 1.6.0 |  N/A  |
 | 4.0.0 | 3.0.0 | 1.5.0 | 1.5.0 | 1.9.0 | 1.7.0 | 2.0.0 | 2.0.0 | 1.5.0 | 1.5.0 |  N/A  |

docs/release_process_quarterly.md

@@ -43,6 +43,31 @@ None
     - [ ] messages get decoded as expected
     - [ ] messages get encoded as expected
 
+#### Details on how to do tests
+
+Run compilation and unit tests in Docker: From the root directory of asn1_codec issue:
+```
+docker build -t acm .
+docker run --env-file .env --name acm -it acm
+```
+In a separate shell:
+```
+docker exec -it acm bash
+/build/acm_tests
+```
+
+where the `.env` file is configured with necessary environment variables.
+
+To test program startup and encoding/decoding:
+
+Pull the release branch into the ODE submodule, and run the ODE via `docker compose up --build -d` from the jpo-ode root directory, with the following profiles set in the `.env` file:
+```
+COMPOSE_PROFILES=ode,adm,aem,kafka,kafka_setup,kafka_ui
+```
+To test decoding send test messages with the `udpsender_generic.py` script and verify the messages are decoded by looking at the `topic.Asn1DecoderOutput` in the kafka UI.
+
+To test encoding, use the Kafka UI to produce one of the decoded messages from `topic.Asn1DecoderOutput` to `topic.Asn1EncoderInput` and check the decoded output appears on `topic.Asn1EncoderOutput`.
+
 ### 3. Project Reference Updates & Release Creation
     - [ ] Merge ‘release/(year)-(quarter)’ branch into ‘master’ branch for the asn1_codec project
     - [ ] Create a release for the asn1_codec project from the ‘master’ branch and tag the release with the version number of the release. (e.g. asn1_codec-x.x.x)
@@ -220,11 +245,13 @@ None
     - [ ] code compiles
         - gradle build
             - [ ] `jpo-asn-j2735-2024` subproject builds via gradle
-            - [ ] `jpo-asn-test-generator` subproject build via gradle
+            - [ ] `jpo-asn-test-generator` subproject builds via gradle
+            - [ ] `jpo-asn-jsonschema-generator` subproject builds via gradle
         - maven build:
             - [ ] `jpo-asn-j2735-2024` subproject builds via maven
     - [ ] unit tests pass
     - [ ] test generator command line tool can generate messages
+    - [ ] schema generator command line tool can generate schemas
 
 ### 3. Project Reference Updates & Release Creation
     - [ ] Update Gradle build version number

jpo-ode-common/pom.xml

@@ -1,18 +1,20 @@
 <?xml version="1.0"?>
-<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+  xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+  xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
   <modelVersion>4.0.0</modelVersion>
 
   <parent>
     <groupId>usdot.jpo.ode</groupId>
     <artifactId>jpo-ode</artifactId>
-    <version>5.1.0</version>
+    <version>6.0.0</version>
   </parent>
-  
+
   <artifactId>jpo-ode-common</artifactId>
   <name>jpo-ode-common</name>
   <description>JPO ODE Common Components</description>
   <packaging>jar</packaging>
-  
+
   <properties>
     <!-- SonarQube Properties -->
     <sonar.exclusions>src/main/java/us/dot/its/jpo/ode/util/GeoUtils.java</sonar.exclusions>
@@ -21,26 +23,26 @@
     <sonar.inclusions>src/main/java/us/dot/its/jpo/ode/inet/*</sonar.inclusions>
   </properties>
 
-  
+
   <dependencies>
     <dependency>
       <groupId>org.json</groupId>
       <artifactId>json</artifactId>
-    <version>20231013</version>
+      <version>20231013</version>
     </dependency>
     <dependency>
       <groupId>com.fasterxml.jackson.core</groupId>
       <artifactId>jackson-databind</artifactId>
     </dependency>
     <dependency>
-    	<groupId>com.fasterxml.jackson.dataformat</groupId>
-    	<artifactId>jackson-dataformat-xml</artifactId>
+      <groupId>com.fasterxml.jackson.dataformat</groupId>
+      <artifactId>jackson-dataformat-xml</artifactId>
     </dependency>
-		<dependency>
+    <dependency>
       <groupId>jakarta.xml.bind</groupId>
       <artifactId>jakarta.xml.bind-api</artifactId>
       <version>4.0.0</version>
-		</dependency>
+    </dependency>
     <dependency>
       <groupId>javax.websocket</groupId>
       <artifactId>javax.websocket-client-api</artifactId>
@@ -52,4 +54,4 @@
       <version>4.0.0</version>
     </dependency>
   </dependencies>
-</project>
+</project>

jpo-ode-core/pom.xml

@@ -7,7 +7,7 @@
   <parent>
     <groupId>usdot.jpo.ode</groupId>
     <artifactId>jpo-ode</artifactId>
-    <version>5.1.0</version>
+    <version>6.0.0</version>
   </parent>
 
   <artifactId>jpo-ode-core</artifactId>
@@ -25,12 +25,12 @@
     <dependency>
       <groupId>usdot.jpo.ode</groupId>
       <artifactId>jpo-ode-common</artifactId>
-      <version>5.1.0</version>
+      <version>6.0.0</version>
     </dependency>
     <dependency>
       <groupId>usdot.jpo.ode</groupId>
       <artifactId>jpo-ode-plugins</artifactId>
-      <version>5.1.0</version>
+      <version>6.0.0</version>
     </dependency>
     <dependency>
       <groupId>org.apache.httpcomponents</groupId>
@@ -90,13 +90,13 @@
     <dependency>
       <groupId>com.networknt</groupId>
       <artifactId>json-schema-validator</artifactId>
-      <version>1.0.76</version>
+      <version>1.0.88</version>
       <scope>test</scope>
     </dependency>
     <dependency>
       <groupId>usdot.jpo.asn</groupId>
       <artifactId>jpo-asn-j2735-2024</artifactId>
-      <version>1.1.0</version>
+      <version>1.2.0</version>
     </dependency>
   </dependencies>
 

jpo-ode-plugins/pom.xml

@@ -1,5 +1,7 @@
 <?xml version="1.0" encoding="UTF-8"?>
-<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+  xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+  xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
   <modelVersion>4.0.0</modelVersion>
 
   <artifactId>jpo-ode-plugins</artifactId>
@@ -11,7 +13,7 @@
   <parent>
     <groupId>usdot.jpo.ode</groupId>
     <artifactId>jpo-ode</artifactId>
-    <version>5.1.0</version>
+    <version>6.0.0</version>
   </parent>
   <properties>
     <!-- SonarQube Properties -->
@@ -27,7 +29,7 @@
     <dependency>
       <groupId>usdot.jpo.ode</groupId>
       <artifactId>jpo-ode-common</artifactId>
-      <version>5.1.0</version>
+      <version>6.0.0</version>
     </dependency>
     <!-- TODO open-ode
     <dependency>
@@ -39,4 +41,4 @@
   </dependencies>
 
 
-</project>
+</project>

jpo-ode-svcs/pom.xml

@@ -6,7 +6,7 @@
   <parent>
     <groupId>usdot.jpo.ode</groupId>
     <artifactId>jpo-ode</artifactId>
-    <version>5.1.0</version>
+    <version>6.0.0</version>
   </parent>
   <artifactId>jpo-ode-svcs</artifactId>
   <packaging>jar</packaging>
@@ -127,12 +127,12 @@
     <dependency>
       <groupId>usdot.jpo.ode</groupId>
       <artifactId>jpo-ode-core</artifactId>
-      <version>5.1.0</version>
+      <version>6.0.0</version>
     </dependency>
     <dependency>
       <groupId>usdot.jpo.ode</groupId>
       <artifactId>jpo-ode-plugins</artifactId>
-      <version>5.1.0</version>
+      <version>6.0.0</version>
     </dependency>
     <dependency>
       <groupId>org.springframework</groupId>
@@ -156,13 +156,13 @@
     <dependency>
       <groupId>com.networknt</groupId>
       <artifactId>json-schema-validator</artifactId>
-      <version>1.0.76</version>
+      <version>1.0.88</version>
       <scope>test</scope>
     </dependency>
     <dependency>
       <groupId>usdot.jpo.asn</groupId>
       <artifactId>jpo-asn-j2735-2024</artifactId>
-      <version>1.1.0</version>
+      <version>1.2.0</version>
     </dependency>
     <dependency>
       <groupId>net.javacrumbs.json-unit</groupId>

jpo-ode-svcs/src/main/java/us/dot/its/jpo/ode/kafka/KafkaConsumerConfig.java

@@ -4,6 +4,7 @@
 import java.util.Map;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.boot.autoconfigure.kafka.KafkaProperties;
+import org.springframework.boot.autoconfigure.kafka.KafkaProperties.Listener;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
 import org.springframework.kafka.annotation.EnableKafka;
@@ -65,6 +66,11 @@ public ConcurrentKafkaListenerContainerFactory<String, String> kafkaListenerCont
     ConcurrentKafkaListenerContainerFactory<String, String> factory =
         new ConcurrentKafkaListenerContainerFactory<>();
     factory.setConsumerFactory(consumerFactory());
+
+    // Set concurrency
+    // Usually set to number of partitions per topic per ode app instance
+    factory.setConcurrency(kafkaProperties.getListener().getConcurrency());
+
     return factory;
   }
 

jpo-ode-svcs/src/main/java/us/dot/its/jpo/ode/udp/controller/UdpServicesController.java

@@ -15,6 +15,7 @@
 import us.dot.its.jpo.ode.udp.bsm.BsmReceiver;
 import us.dot.its.jpo.ode.udp.generic.GenericReceiver;
 import us.dot.its.jpo.ode.udp.map.MapReceiver;
+import us.dot.its.jpo.ode.udp.portmapped.PortMappedIngestConfigLoader;
 import us.dot.its.jpo.ode.udp.psm.PsmReceiver;
 import us.dot.its.jpo.ode.udp.rsm.RsmReceiver;
 import us.dot.its.jpo.ode.udp.rtcm.RtcmReceiver;
@@ -44,7 +45,8 @@ public class UdpServicesController {
   @Autowired
   public UdpServicesController(UDPReceiverProperties udpProps,
                                RawEncodedJsonTopics rawEncodedJsonTopics,
-                               KafkaTemplate<String, String> kafkaTemplate) {
+                               KafkaTemplate<String, String> kafkaTemplate,
+                               PortMappedIngestConfigLoader portMappedIngestConfigLoader) {
 
     log.debug("Starting UDP receiver services...");
 
@@ -60,6 +62,13 @@ public UdpServicesController(UDPReceiverProperties udpProps,
     startReceiver(new RsmReceiver(udpProps.getRsm(), kafkaTemplate, rawEncodedJsonTopics.getRsm()));
     startReceiver(new GenericReceiver(udpProps.getGeneric(), kafkaTemplate, rawEncodedJsonTopics));
 
+
+    List<AbstractUdpReceiverPublisher> receivers = portMappedIngestConfigLoader
+      .loadReceivers(udpProps, rawEncodedJsonTopics, kafkaTemplate);
+    for (AbstractUdpReceiverPublisher receiver : receivers) {
+      startReceiver(receiver);
+    }
+
     log.debug("UDP receiver services started.");
   }
 

jpo-ode-svcs/src/main/java/us/dot/its/jpo/ode/udp/generic/GenericReceiver.java

@@ -115,7 +115,7 @@ private static String describePacketForLog(DatagramPacket packet) {
     return sb.toString();
   }
 
-  private void routeMessageByMessageType(String messageType, DatagramPacket packet)
+  protected void routeMessageByMessageType(String messageType, DatagramPacket packet)
       throws InvalidPayloadException, UnsupportedMessageTypeException {
     log.debug("Detected Message Type {}", messageType);
     switch (messageType) {