Skip to content

Test Intersection Reference Alignment Events

Ivan Yourshaw edited this page Aug 20, 2025 · 6 revisions

Intersection Reference Alignment Event

Note: Intersection Reference Alignment Events can be configured to enable aggregation using the map.spat.message.assessment.aggregateIntersectionReferenceAlignmentEvents configuration setting, or the ENABLE_AGGREGATE_INTERSECTION_REFERENCE_ALIGNMENT_EVENTS environment variable. If aggregation is enabled, events will be delayed by up to the configured aggregation.interval, which is 60 seconds by default.

1. Should produce Alignment Event

Inputs

One MAP and several SPATs from the same RSU IP with different intersection ID and road regulator IDs.

MAP: intersection ID = 12109, road regulator ID = 1

SPAT: intersection ID = 99999, road regulator ID = 9

Test Data Files

Script-SPAT-MAP-unaligned.csv

Output Topics

If aggregation is enabled, events are output to:

  • topic.CmIntersectionReferenceAlignmentEventAggregation

If aggregation is disabled, events are output to:

  • topic.CmIntersectionReferenceAlignmentEvents

Without Aggregation

Expected Output

Several alignment events.

Actual Output

Several events similar to:

Topic: topic.CmIntersectionReferenceAlignmentEvents
Key: 10.11.81.12
{
	"eventGeneratedAt": 1755659516711,
	"eventType": "IntersectionReferenceAlignment",
	"intersectionID": 99999,
	"roadRegulatorID": 9,
	"source": "10.11.81.12",
	"timestamp": 1755659516133,
	"spatRegulatorIntersectionIds": [
		{
			"roadRegulatorId": 9,
			"intersectionId": 99999
		}
	],
	"mapRegulatorIntersectionIds": [
		{
			"roadRegulatorId": 1,
			"intersectionId": 12109
		}
	]
}

With Aggregation

TODO

Comments

2. Should not produce Alignment Event

Inputs

One MAP and several SPATs with matching RSU IP, intersection IDs, and road regulator IDs. SPAT send interval 100 ms.

Intersection ID = 12109, road regulator ID = 1 for both

Test Data Files

Script-SPAT-MAP.csv

Without Aggregation

Expected Output

No events.

Actual Output

No events.

Comments

With Aggregation

TODO

Clone this wiki locally