Uses of Interface
io.axoniq.framework.messaging.eventstreaming.checkpoint.CheckpointTrigger

Packages that use CheckpointTrigger

Package	Description
io.axoniq.framework.messaging.eventstreaming.checkpoint	Part of the Axoniq Framework event-streaming module.
io.axoniq.framework.workflow.runtime.execution	Internal implementation of the workflow execution engine: the WorkflowEngine, its scheduling, state and storage, checkpointing/replay support, cancellation coordination, and the delegates implementing individual step primitives.

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

Fields in io.axoniq.framework.messaging.eventstreaming.checkpoint with type parameters of type CheckpointTrigger

Modifier and Type	Field	Description
static final Context.ResourceKey<CheckpointTrigger>	CheckpointTrigger.RESOURCE_KEY	The Context.ResourceKey under which the per-segment CheckpointTrigger is made available in the active ProcessingContext during event handling.

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

Modifier and Type	Method	Description
@Nullable ParameterResolver<CheckpointTrigger>	CheckpointTriggerParameterResolverFactory.createInstance(Executable executable, Parameter[] parameters, int parameterIndex)
static Optional<CheckpointTrigger>	CheckpointTrigger.fromContext(Context context)	Returns an Optional of the CheckpointTrigger keyed under RESOURCE_KEY in the given context, or Optional.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 CheckpointTrigger

Modifier and Type	Method	Description
default void	Checkpointing.onSegmentClaimed(Segment segment, @Nullable TrackingToken from, CheckpointTrigger trigger)	Invoked when segment is claimed, handing the unit the CheckpointTrigger it uses to declare safe positions for that segment.

Uses of CheckpointTrigger in io.axoniq.framework.workflow.runtime.execution

Methods in io.axoniq.framework.workflow.runtime.execution with parameters of type CheckpointTrigger

Modifier and Type	Method	Description
void	CheckpointingEventHandlingComponentHandlingAny.onSegmentClaimed(Segment segment, @Nullable TrackingToken from, CheckpointTrigger trigger)
void	WorkflowEngineCheckpointingSupport.onSegmentClaimed(Segment segment, @Nullable TrackingToken from, CheckpointTrigger trigger)