Uses of Interface
io.axoniq.framework.messaging.eventstreaming.checkpoint.CheckpointTrigger
Packages that use CheckpointTrigger
Package
Description
Part of the Axoniq Framework event-streaming module.
-
Uses of CheckpointTrigger in io.axoniq.framework.messaging.eventstreaming.checkpoint
Fields in io.axoniq.framework.messaging.eventstreaming.checkpoint with type parameters of type CheckpointTriggerModifier and TypeFieldDescriptionstatic final Context.ResourceKey<CheckpointTrigger> CheckpointTrigger.RESOURCE_KEYTheContext.ResourceKeyunder which the per-segmentCheckpointTriggeris made available in the activeProcessingContextduring event handling.Methods in io.axoniq.framework.messaging.eventstreaming.checkpoint that return types with arguments of type CheckpointTriggerModifier and TypeMethodDescription@Nullable ParameterResolver<CheckpointTrigger> CheckpointTriggerParameterResolverFactory.createInstance(Executable executable, Parameter[] parameters, int parameterIndex) static Optional<CheckpointTrigger> CheckpointTrigger.fromContext(Context context) Returns anOptionalof theCheckpointTriggerkeyed underRESOURCE_KEYin the givencontext, orOptional.empty()if none is present (for example, in a processor that does not checkpoint).Methods in io.axoniq.framework.messaging.eventstreaming.checkpoint with parameters of type CheckpointTriggerModifier and TypeMethodDescriptiondefault voidCheckpointing.onSegmentClaimed(Segment segment, CheckpointTrigger trigger) Invoked whensegmentis claimed, handing the unit theCheckpointTriggerit uses to declare safe positions for that segment.