Package io.axoniq.framework.messaging.eventstreaming.checkpoint

@NullMarked package io.axoniq.framework.messaging.eventstreaming.checkpoint

Part of the Axoniq Framework event-streaming module. Contains the checkpoint protocol that lets an event-handling unit manage its own progress: it decides when its work for a segment is durable and requests the owning streaming processor to advance the stored TrackingToken.

Related Packages

Package	Description
io.axoniq.framework.messaging.eventstreaming	Part of the Axoniq Messaging folder.

Class	Description
Checkpointing	Declares that an event-handling unit manages its own progress: it decides when its work for a Segment is durable and asks the processor to advance the stored TrackingToken through a CheckpointTrigger.
CheckpointingAxoniqAddon	AxoniqAddon implementation for the Axoniq Framework self-checkpointing event handlers.
CheckpointingConfigurationEnhancer	A ConfigurationEnhancer that enables self-checkpointing support for pooled streaming event processors.
CheckpointingProgressStrategy	SegmentProgressStrategy that lets self-checkpointing Checkpointing units manage when their segment's stored TrackingToken advances.
CheckpointingProgressStrategyFactory	SegmentProgressStrategyFactory that produces a CheckpointingProgressStrategy for every segment of a processor whose components include one or more self-checkpointing Checkpointing units.
CheckpointTrigger	Handle through which a Checkpointing unit tells the owning processor how far it is safe to advance the stored TrackingToken for a single claimed Segment.
CheckpointTriggerParameterResolverFactory	A ParameterResolverFactory constructing a ParameterResolver resolving the CheckpointTrigger for the segment currently being handled.