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

Packages that use SegmentProgressStrategyFactory

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

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

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

Modifier and Type	Class	Description
final class	CheckpointingProgressStrategyFactory	SegmentProgressStrategyFactory that produces a CheckpointingProgressStrategy for every segment of a processor whose components include one or more self-checkpointing Checkpointing units.

Methods in io.axoniq.framework.messaging.eventstreaming.checkpoint that return types with arguments of type SegmentProgressStrategyFactory

Modifier and Type	Method	Description
static Function<List<EventHandlingComponent>,SegmentProgressStrategyFactory>	CheckpointingProgressStrategyFactory.detecting()	Returns the component-driven selector used to pick a SegmentProgressStrategyFactory for a processor: a CheckpointingProgressStrategyFactory when its components include self-checkpointing Checkpointing units, otherwise the default token-storing factory.

Uses of SegmentProgressStrategyFactory in org.axonframework.messaging.eventhandling.processing.streaming.pooled

Methods in org.axonframework.messaging.eventhandling.processing.streaming.pooled that return types with arguments of type SegmentProgressStrategyFactory

Modifier and Type	Method	Description
Function<List<EventHandlingComponent>,SegmentProgressStrategyFactory>	PooledStreamingEventProcessorConfiguration.progressStrategyFactoryBuilder()	Returns the function selecting the SegmentProgressStrategyFactory for a processor from its EventHandlingComponents.

Method parameters in org.axonframework.messaging.eventhandling.processing.streaming.pooled with type arguments of type SegmentProgressStrategyFactory

Modifier and Type	Method	Description
PooledStreamingEventProcessorConfiguration	PooledStreamingEventProcessorConfiguration.progressStrategyFactoryBuilder(Function<List<EventHandlingComponent>,SegmentProgressStrategyFactory> progressStrategyFactoryBuilder)	Sets the function selecting the SegmentProgressStrategyFactory for a processor from its EventHandlingComponents.

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

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

Modifier and Type	Method	Description
static SegmentProgressStrategyFactory	SegmentProgressStrategyFactory.tokenStoring()	Returns the default factory, producing a TokenStoringProgressStrategy that persists the batch-end token every batch.