Package io.axoniq.framework.workflow.runtime.execution

@NullMarked package 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.

Since:

5.4.0

Related Packages

Package	Description
io.axoniq.framework.workflow.runtime.execution.payload	PayloadReducer implementations and their registry, combining or selecting between the global (workflow context) and local payloads passed to and returned from workflow steps.

Class	Description
AbstractStepExecutor	Abstract class for step executor implementations.
AbstractWorkflowContext	Base class for author-facing WorkflowContext implementations.
AllMatchCombinatorDelegate	Default implementation of AllMatchCombinator.
AnyMatchCombinatorDelegate	Default implementation of AnyMatchCombinator.
CheckpointingEventHandlingComponentHandlingAny	Event handling component handling any event, which is checkpoint-aware.
DefaultEventNameCustomizer	Default implementation of EventNameCustomizer that builds event names from a base name and status suffix.
DefaultEventNameCustomizer.Builder	Builder for DefaultEventNameCustomizer.
DefaultEventNameCustomizer.PayloadCustomization	Data class containing information for payload customization.
DefaultExecuteStepActionResolver	Default action resolver that invokes the action supplied by the workflow definition.
DefaultWorkflowScheduler	Wall-clock timeout scheduler used in production.
EventHandlingComponentHandlingAny	Event handling component handling any event.
EventSourcedRunningWorkflows	Event sourced collection of running workflow IDs, loaded by WorkflowStore.
EventSourcedWorkflowState	Holds the current state of a workflow and modified by the EventSourcedWorkflowState.evolve(org.axonframework.messaging.eventhandling.EventMessage, org.axonframework.messaging.core.unitofwork.ProcessingContext) method receiving messages.
EventSourcedWorkflowStore	Event-sourcing repository-backed workflow store.
ExecuteDelegate	Execute delegate implementing ExecutePrimitive.
ExecuteStepActionResolver	Resolves the action to invoke for an "execute step".
InMemoryWorkflowExecutionRepository	In-memory implementation of WorkflowExecutionRepository backed by a ConcurrentHashMap.
MessageWorkflowIdProvider	Workflow id provider using the message identifier as workflow id.
NoneMatchCombinatorDelegate	Default implementation of NoneMatchCombinator.
PayloadDelegate	Primitive implementing durable payload modifications.
PayloadPropertyWorkflowIdProvider	Workflow id provider accessing event message property.
PublishDelegate	Implements the PublishPrimitive.
ReachedSteps	Records steps reached by one workflow body invocation for replay-drift detection.
RetryableExecuteDelegate	Decorator that adds retry behavior to an ExecuteDelegate.
RunningSteps	Tracks running CompletableFutures for workflow steps, keyed by step name.
RunningWorkflows	Identifies workflow instances that have started and have not yet reached a terminal state.
SimpleWorkflowConfigurationRegistry	In-memory workflow definition registry implementation.
SimpleWorkflowExecution	Workflow instance implementation.
SimpleWorkflowManager	Workflow Manager backed by the workflow history projection and live cancellation coordinators.
StateBasedWorkflowStepResult	Workflow Step result based on the Workflow State.
StateBasedWorkflowStepResult.StateChangeTrigger	Blocks until the workflow state changes.
UnrecognizedWorkflowDefinitionException	Thrown when a WorkflowEngine cannot resolve a workflow configuration for a durable workflow definition it encountered while restoring a segment.
VersionDelegate	Implements the VersionPrimitive.
WaitForDelegate	Delegate implementing WaitForPrimitive.
WorkflowAxoniqAddon	Definition of the AxoniqAddon for licensing, loaded through SPI during boot to log its existence to the user, and warn that a license is needed.
WorkflowCancellation	Coordinates cancellation requests for one running workflow instance.
WorkflowCancellation.PendingRequest	Represents one pending workflow-cancellation request owned by the cancellation coordinator.
WorkflowCancellation.Request	Provides pending workflow-cancellation requests to the workflow driver.
WorkflowCancellationService	Internal entry point for requesting cancellation of running workflows by identifier.
WorkflowConfigurationRegistry<W extends WorkflowConfigurationRegistry<W>>	Registry for holding workflow configurations with corresponding start conditions.
WorkflowConfigurationRegistry.PredicatedWorkflowConfiguration
WorkflowConfigurationRegistry.RoutingLog	Holder for the SLF4J logger used by routing decisions (interfaces cannot have static loggers directly).
WorkflowContextAdoptingExecutionFactory<C extends WorkflowContext>	Workflow execution factory adopting an author-facing context implementing AbstractWorkflowContext.
WorkflowEngine	Main workflow component responsible for managing and executing workflows.
WorkflowEngineCheckpointingSupport	A Checkpointing implementation dedicated for a WorkflowEngine, to separate check pointing behavior from it.
WorkflowEngineCheckpointingSupport.CheckpointLatchCoordinator	Coordinates workflow work that must complete before checkpoint advancement.
WorkflowEventTagResolver	Resolves workflow-specific event-store tags for engine-published events.
WorkflowEventTags	Constant holder for workflow event tags.
WorkflowExecutionOperationsDelegation	Implementation of WorkflowExecutionOperations that delegates all operations to the underlying WorkflowExecution and primitive implementations.
WorkflowExecutionRepository	Repository for retrieving workflow executions, storing new ones, and removing them.
WorkflowLifecycleControlDelegate	Delegate that applies workflow and step lifecycle-control commands on the workflow control thread.
WorkflowScheduler	Delivers workflow timeout and retry-backoff deadlines.
WorkflowScheduler.ScheduledTask	Scheduled task handle.
WorkflowStepResults	Utility containing WorkflowStepResult factory methods.
WorkflowStore	Narrow adapter around workflow-state repositories used during startup.