Uses of Interface
org.axonframework.messaging.eventhandling.processing.streaming.progress.SegmentProgressStrategy

Packages that use SegmentProgressStrategy

Package	Description
io.axoniq.framework.messaging.eventstreaming.checkpoint	Part of the Axoniq Framework event-streaming module.
org.axonframework.messaging.eventhandling.processing.streaming.progress	Part of the Axon Messaging module.

Uses of SegmentProgressStrategy in io.axoniq.framework.messaging.eventstreaming.checkpoint

Classes in io.axoniq.framework.messaging.eventstreaming.checkpoint that implement SegmentProgressStrategy

Modifier and Type	Class	Description
final class	CheckpointingProgressStrategy	SegmentProgressStrategy that lets self-checkpointing Checkpointing units manage when their segment's stored TrackingToken advances.

Methods in io.axoniq.framework.messaging.eventstreaming.checkpoint that return SegmentProgressStrategy

Modifier and Type	Method	Description
SegmentProgressStrategy	CheckpointingProgressStrategyFactory.create(SegmentProgressContext context)

Uses of SegmentProgressStrategy in org.axonframework.messaging.eventhandling.processing.streaming.progress

Classes in org.axonframework.messaging.eventhandling.processing.streaming.progress that implement SegmentProgressStrategy

Modifier and Type	Class	Description
final class	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.

Methods in org.axonframework.messaging.eventhandling.processing.streaming.progress that return SegmentProgressStrategy

Modifier and Type	Method	Description
SegmentProgressStrategy	SegmentProgressStrategyFactory.create(SegmentProgressContext context)	Creates the SegmentProgressStrategy for the segment owning the given context.