Uses of Interface
io.axoniq.framework.workflow.runtime.api.execution.context.WorkflowExecution

Packages that use WorkflowExecution

Package	Description
io.axoniq.framework.workflow.runtime.api.execution.context	Internal runtime contracts for workflow execution, command dispatch, configuration, and event publication.
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.
io.axoniq.framework.workflow.runtime.test.fixture	The given/when/then style test fixture API for workflow runtime tests, including the staged WorkflowTestFixture, the lower-level WorkflowTestDriver, and the shared testing state and services backing both.
io.axoniq.framework.workflow.runtime.test.utils	Test-only utility components used by the workflow test fixture and configuration, such as manual execution and scheduling controls, a mutable test clock, id generation, event publication helpers, and a pretty-printing recording event store.

Uses of WorkflowExecution in io.axoniq.framework.workflow.runtime.api.execution.context

Methods in io.axoniq.framework.workflow.runtime.api.execution.context that return WorkflowExecution

Modifier and Type	Method	Description
WorkflowExecution	WorkflowExecutionFactory.create(WorkflowContext workflowContext)	Creates workflow execution for a given workflow context.

Methods in io.axoniq.framework.workflow.runtime.api.execution.context that return types with arguments of type WorkflowExecution

Modifier and Type	Method	Description
@Nullable Consumer<WorkflowExecution>	WorkflowExecution.getNextTask()	Returns and removes the next queued task.

Method parameters in io.axoniq.framework.workflow.runtime.api.execution.context with type arguments of type WorkflowExecution

Modifier and Type	Method	Description
void	WorkflowExecution.appendTask(Consumer<WorkflowExecution> task)	Appends a task for execution by the workflow control thread.
CompletableFuture<Void>	WorkflowExecution.execute(Consumer<WorkflowExecution> terminationHandler)	Executes the workflow body.

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

Classes in io.axoniq.framework.workflow.runtime.execution that implement WorkflowExecution

Modifier and Type	Class	Description
final class	SimpleWorkflowExecution	Workflow instance implementation.

Fields in io.axoniq.framework.workflow.runtime.execution declared as WorkflowExecution

Modifier and Type	Field	Description
protected final WorkflowExecution	AbstractStepExecutor.workflowExecution

Methods in io.axoniq.framework.workflow.runtime.execution that return WorkflowExecution

Modifier and Type	Method	Description
WorkflowExecution	WorkflowContextAdoptingExecutionFactory.create(WorkflowContext workflowContext)
WorkflowExecution	InMemoryWorkflowExecutionRepository.remove(String workflowId)
WorkflowExecution	WorkflowExecutionRepository.remove(String workflowId)	Removes the workflow execution associated with the given identifier.
WorkflowExecution	InMemoryWorkflowExecutionRepository.save(String workflowId, Supplier<WorkflowExecution> factory)
WorkflowExecution	WorkflowExecutionRepository.save(String workflowId, Supplier<WorkflowExecution> factory)	Atomically stores a new workflow execution if no execution exists for the given workflow identifier.

Methods in io.axoniq.framework.workflow.runtime.execution that return types with arguments of type WorkflowExecution

Modifier and Type	Method	Description
CompletableFuture<Set<WorkflowExecution>>	InMemoryWorkflowExecutionRepository.findAll(WorkflowStateQuery query)
Set<WorkflowExecution>	InMemoryWorkflowExecutionRepository.findAll(Predicate<WorkflowExecution> predicate)
default Set<WorkflowExecution>	WorkflowExecutionRepository.findAll()	Returns all stored workflow executions, with at most one execution per workflow identifier.
CompletableFuture<Set<WorkflowExecution>>	WorkflowExecutionRepository.findAll(WorkflowStateQuery query)	Returns all stored workflow executions whose state matches a query.
Set<WorkflowExecution>	WorkflowExecutionRepository.findAll(Predicate<WorkflowExecution> predicate)	Returns all stored workflow executions matching the given predicate, with at most one execution per workflow identifier.
Optional<WorkflowExecution>	InMemoryWorkflowExecutionRepository.findById(String workflowId)
Optional<WorkflowExecution>	WorkflowExecutionRepository.findById(String workflowId)	Finds a workflow execution by its identifier.
@Nullable Consumer<WorkflowExecution>	SimpleWorkflowExecution.getNextTask()
Set<WorkflowExecution>	WorkflowEngine.workflowExecutions()	Retrieve all workflow executions.

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

Modifier and Type	Method	Description
PayloadProcessor	DefaultExecuteStepActionResolver.resolve(WorkflowExecutionOperations workflowExecutionOperations, WorkflowExecution workflowExecution, ExecutePrimitive.ExecuteCommand command)
PayloadProcessor	ExecuteStepActionResolver.resolve(WorkflowExecutionOperations workflowExecutionOperations, WorkflowExecution workflowExecution, ExecutePrimitive.ExecuteCommand command)	Resolve the action for the given execute command.
static WorkflowStepResult	AbstractStepExecutor.stateBased(String stepName, EventNameCustomizer eventNameCustomizer, WorkflowExecution workflowExecution)	Creates a durable result handle for a step while retaining its event-name customizer for later cancellation.

Method parameters in io.axoniq.framework.workflow.runtime.execution with type arguments of type WorkflowExecution

Modifier and Type	Method	Description
void	SimpleWorkflowExecution.appendTask(Consumer<WorkflowExecution> task)
CompletableFuture<Void>	SimpleWorkflowExecution.execute(Consumer<WorkflowExecution> terminationHandler)	Executes the workflow body.
Set<WorkflowExecution>	InMemoryWorkflowExecutionRepository.findAll(Predicate<WorkflowExecution> predicate)
Set<WorkflowExecution>	WorkflowExecutionRepository.findAll(Predicate<WorkflowExecution> predicate)	Returns all stored workflow executions matching the given predicate, with at most one execution per workflow identifier.
void	InMemoryWorkflowExecutionRepository.removeAll(Predicate<WorkflowExecution> predicate)
void	WorkflowExecutionRepository.removeAll(Predicate<WorkflowExecution> predicate)	Removes all workflow executions matching the given predicate.
WorkflowExecution	InMemoryWorkflowExecutionRepository.save(String workflowId, Supplier<WorkflowExecution> factory)
WorkflowExecution	WorkflowExecutionRepository.save(String workflowId, Supplier<WorkflowExecution> factory)	Atomically stores a new workflow execution if no execution exists for the given workflow identifier.

Constructors in io.axoniq.framework.workflow.runtime.execution with parameters of type WorkflowExecution

Modifier	Constructor	Description
	AbstractStepExecutor(WorkflowExecutionOperations workflowExecutionOperations, WorkflowExecution workflowExecution, RunningSteps runningSteps, ReachedSteps reachedSteps, EventNameCustomizer parentEventNameCustomizer, Clock clock, WorkflowScheduler timeoutScheduler)	Constructs the abstract step executor.
	AllMatchCombinatorDelegate(WorkflowExecution workflowExecution)	Creates a new delegate backed by the given workflow state.
	AnyMatchCombinatorDelegate(WorkflowExecution workflowExecution)	Creates a new delegate backed by the given workflow state.
	ExecuteDelegate(WorkflowExecutionOperations workflowExecutionOperations, WorkflowExecution workflowExecution, RunningSteps runningSteps, ReachedSteps reachedSteps, EventNameCustomizer parentEventNameCustomizer, Clock clock, UnitOfWorkFactory unitOfWorkFactory, Executor executor, WorkflowScheduler timeoutScheduler, ExecuteStepActionResolver actionResolver)	Constructs the delegate.
	NoneMatchCombinatorDelegate(WorkflowExecution workflowExecution)	Creates a new delegate backed by the given workflow state.
	PayloadDelegate(WorkflowExecutionOperations workflowExecutionOperations, WorkflowExecution workflowExecution, RunningSteps runningSteps, ReachedSteps reachedSteps, EventNameCustomizer parentEventNameCustomizer, Clock clock, WorkflowScheduler timeoutScheduler)	Constructs the primitive implementation.
	PublishDelegate(WorkflowExecution workflowExecution, ReachedSteps reachedSteps)	Constructs the delegate.
	RetryableExecuteDelegate(ExecuteDelegate delegate, WorkflowExecutionOperations workflowExecutionOperations, WorkflowExecution workflowExecution, RunningSteps runningSteps, ReachedSteps reachedSteps, EventNameCustomizer parentEventNameCustomizer, Clock clock, WorkflowScheduler timeoutScheduler)	Constructs the delegate.
	StateBasedWorkflowStepResult(String stepName, StateBasedWorkflowStepResult.StateChangeTrigger stateChangeTrigger, Consumer<Throwable> cancellation, WorkflowExecution state)	Creates a result backed by the current workflow execution state.
	VersionDelegate(WorkflowExecutionOperations workflowExecutionOperations, WorkflowExecution workflowExecution, ReachedSteps reachedSteps, EventNameCustomizer parentEventNameCustomizer, Clock clock)	Constructs the delegate.
	WaitForDelegate(WorkflowExecutionOperations workflowExecutionOperations, WorkflowExecution workflowExecution, RunningSteps runningSteps, io.axoniq.framework.workflow.runtime.execution.EventWaitConditions eventWaitConditions, ReachedSteps reachedSteps, EventNameCustomizer parentEventNameCustomizer, Clock clock, WorkflowScheduler timeoutScheduler)	Constructs the delegate.
	WorkflowExecutionOperationsDelegation(WorkflowConfiguration<?> workflowConfiguration, WorkflowContext workflowContext, WorkflowExecution workflowExecution, RunningSteps runningSteps, io.axoniq.framework.workflow.runtime.execution.EventWaitConditions eventWaitConditions, ReachedSteps reachedSteps, io.axoniq.framework.workflow.runtime.execution.WorkflowTerminalTransition terminalTransition, ProcessingContext processingContext)	Creates the context delegation.
	WorkflowLifecycleControlDelegate(WorkflowExecutionOperations workflowExecutionOperations, WorkflowExecution workflowExecution, RunningSteps runningSteps, ReachedSteps reachedSteps, io.axoniq.framework.workflow.runtime.execution.WorkflowTerminalTransition terminalTransition)	Constructs a lifecycle-control delegate.

Uses of WorkflowExecution in io.axoniq.framework.workflow.runtime.test.fixture

Methods in io.axoniq.framework.workflow.runtime.test.fixture that return WorkflowExecution

Modifier and Type	Method	Description
WorkflowExecution	WorkflowEngineTestingState.execution()	Returns the current workflow execution.
WorkflowExecution	DefaultWorkflowTestDriver.executionExists()
WorkflowExecution	WorkflowTestDriver.executionExists()	Waits until an active workflow execution exists.
WorkflowExecution	DefaultWorkflowTestDriver.executionMatches(Predicate<WorkflowExecution> predicate)
WorkflowExecution	WorkflowTestDriver.executionMatches(Predicate<WorkflowExecution> predicate)	Waits until an active workflow execution matching the predicate exists.

Method parameters in io.axoniq.framework.workflow.runtime.test.fixture with type arguments of type WorkflowExecution

Modifier and Type	Method	Description
WorkflowExecution	DefaultWorkflowTestDriver.executionMatches(Predicate<WorkflowExecution> predicate)
WorkflowExecution	WorkflowTestDriver.executionMatches(Predicate<WorkflowExecution> predicate)	Waits until an active workflow execution matching the predicate exists.
void	DefaultWorkflowTestDriver.executionSatisfies(Consumer<WorkflowExecution> executionConsumer)
void	WorkflowTestDriver.executionSatisfies(Consumer<WorkflowExecution> executionConsumer)	Waits until an active workflow execution exists and applies the given consumer.

Uses of WorkflowExecution in io.axoniq.framework.workflow.runtime.test.utils

Methods in io.axoniq.framework.workflow.runtime.test.utils with parameters of type WorkflowExecution

Modifier and Type	Method	Description
PayloadProcessor	ManualExecuteStepActionResolver.resolve(WorkflowExecutionOperations workflowExecutionOperations, WorkflowExecution workflowExecution, ExecutePrimitive.ExecuteCommand command)	Resolves the action for an execute step, blocking until the fixture supplies behavior for the step name.