Uses of Interface
io.axoniq.framework.workflow.runtime.execution.WorkflowScheduler
Packages that use WorkflowScheduler
Package
Description
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.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 WorkflowScheduler in io.axoniq.framework.workflow.runtime.execution
Classes in io.axoniq.framework.workflow.runtime.execution that implement WorkflowSchedulerModifier and TypeClassDescriptionclassWall-clock timeout scheduler used in production.Fields in io.axoniq.framework.workflow.runtime.execution declared as WorkflowSchedulerModifier and TypeFieldDescriptionprotected final WorkflowSchedulerAbstractStepExecutor.timeoutSchedulerConstructors in io.axoniq.framework.workflow.runtime.execution with parameters of type WorkflowSchedulerModifierConstructorDescriptionAbstractStepExecutor(WorkflowExecutionOperations workflowExecutionOperations, WorkflowExecution workflowExecution, RunningSteps runningSteps, ReachedSteps reachedSteps, EventNameCustomizer parentEventNameCustomizer, Clock clock, WorkflowScheduler timeoutScheduler) Constructs the abstract step executor.ExecuteDelegate(WorkflowExecutionOperations workflowExecutionOperations, WorkflowExecution workflowExecution, RunningSteps runningSteps, ReachedSteps reachedSteps, EventNameCustomizer parentEventNameCustomizer, Clock clock, UnitOfWorkFactory unitOfWorkFactory, Executor executor, WorkflowScheduler timeoutScheduler, ExecuteStepActionResolver actionResolver) Constructs the delegate.PayloadDelegate(WorkflowExecutionOperations workflowExecutionOperations, WorkflowExecution workflowExecution, RunningSteps runningSteps, ReachedSteps reachedSteps, EventNameCustomizer parentEventNameCustomizer, Clock clock, WorkflowScheduler timeoutScheduler) Constructs the primitive implementation.RetryableExecuteDelegate(ExecuteDelegate delegate, WorkflowExecutionOperations workflowExecutionOperations, WorkflowExecution workflowExecution, RunningSteps runningSteps, ReachedSteps reachedSteps, EventNameCustomizer parentEventNameCustomizer, Clock clock, WorkflowScheduler timeoutScheduler) 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. -
Uses of WorkflowScheduler in io.axoniq.framework.workflow.runtime.test.utils
Classes in io.axoniq.framework.workflow.runtime.test.utils that implement WorkflowSchedulerModifier and TypeClassDescriptionclassManual timeout scheduler driven by the fixture clock.