Package org.axonframework.messaging.eventhandling.processing.streaming.progress

@NullMarked package org.axonframework.messaging.eventhandling.processing.streaming.progress

Part of the Axon Messaging module. Defines the per-segment progress-persistence seam for streaming event processing. A SegmentProgressStrategy is invoked around each batch (and on claim/release) to decide which TrackingToken to persist, while a SegmentProgressContext performs the actual store for the segment. The default TokenStoringProgressStrategy stores the batch-end token; advanced strategies (such as self-checkpointing) plug in through the same seam.

Related Packages

Package	Description
org.axonframework.messaging.eventhandling.processing.streaming	Part of the Axon Messaging module.
org.axonframework.messaging.eventhandling.processing.streaming.pooled	Part of the Axon Messaging module.
org.axonframework.messaging.eventhandling.processing.streaming.segmenting	Part of the Axon Messaging module.
org.axonframework.messaging.eventhandling.processing.streaming.token	Part of the Axon Messaging module.

Class	Description
SegmentProgressContext	The handle a SegmentProgressStrategy uses to observe and persist the progress of the single Segment it is bound to, provided to the strategy on creation.
SegmentProgressStrategy	Decides how a single Segment's progress is persisted as its events are processed.
SegmentProgressStrategyFactory	Creates a SegmentProgressStrategy for a single segment, binding it to that segment's SegmentProgressContext.
TokenStoringProgressStrategy	Default SegmentProgressStrategy: persists the batch-end token (SegmentProgressContext.lastConsumedToken()) on every commit, so the stored TrackingToken advances to the position consumed by each batch.