Uses of Record Class
io.axoniq.framework.workflow.dsl.api.ExecuteStepDefinition
Packages that use ExecuteStepDefinition
Package
Description
Base Java DSL for defining workflow steps, providing the core primitives to execute work, wait for events, modify the
workflow payload, sleep, fail, and cancel a workflow.
Convenience Java DSL built on top of the base DSL, adding shortcuts for common workflow steps such as executing
without extra input payload, waiting for a typed event, and replacing the workflow payload outright.
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 ExecuteStepDefinition in io.axoniq.framework.workflow.dsl.api
Methods in io.axoniq.framework.workflow.dsl.api that return ExecuteStepDefinitionModifier and TypeMethodDescriptionExecuteStepDefinition.action(PayloadProcessor action) Returns a copy of this definition with the provided action.ExecuteStepDefinition.eventNameCustomizer(EventNameCustomizer eventNameCustomizer) Returns a copy of this definition with the provided event name customizer.ExecuteStepDefinition.inputPayload(Map<String, @Nullable Object> inputPayload) Returns a copy of this definition with the provided step-local input payload.ExecuteStepDefinition.parameterPayloadReducer(PayloadReducer parameterPayloadReducer) Returns a copy of this definition with the provided parameter payload reducer.ExecuteStepDefinition.payloadMapping(PayloadMapping payloadMapping) Returns a copy of this definition with the provided payload mapping.ExecuteStepDefinition.primitiveMetadata(PrimitiveMetadata primitiveMetadata) Returns a copy of this definition with the provided primitive metadata.ExecuteStepDefinition.resultPayloadReducer(PayloadReducer resultPayloadReducer) Returns a copy of this definition with the provided result payload reducer.ExecuteStepDefinition.retryPolicy(RetryPolicy retryPolicy) Returns a copy of this definition with the provided retry policy.Returns a copy of this definition with the provided step name.ExecuteStepDefinition.timeout(long timeoutSeconds) Returns a copy of this definition with the provided timeout in seconds.Returns a copy of this definition with the provided timeout.Returns a copy of this definition with the provided timing configuration.Methods in io.axoniq.framework.workflow.dsl.api with parameters of type ExecuteStepDefinitionModifier and TypeMethodDescriptionWorkflowContext.awaitExecute(ExecuteStepDefinition stepDefinition) Executes a step synchronously from a DSL step definition and returns the resulting step payload.WorkflowContext.execute(ExecuteStepDefinition stepDefinition) Executes a step asynchronously from a DSL step definition. -
Uses of ExecuteStepDefinition in io.axoniq.framework.workflow.dsl.base
Methods in io.axoniq.framework.workflow.dsl.base that return ExecuteStepDefinitionModifier and TypeMethodDescriptionBaseWorkflowContext.defaultExecuteStepDefinition(String stepName, Map<String, @Nullable Object> inputPayload, PayloadProcessor processor) Creates the default execute step definition used by the convenience overloads in this class.Method parameters in io.axoniq.framework.workflow.dsl.base with type arguments of type ExecuteStepDefinitionModifier and TypeMethodDescriptionBaseWorkflowContext.awaitExecute(String stepName, Map<String, @Nullable Object> inputPayload, PayloadProcessor processor, UnaryOperator<ExecuteStepDefinition> customizer) Starts an execute step and blocks until it completes.BaseWorkflowContext.execute(String stepName, Map<String, @Nullable Object> inputPayload, PayloadProcessor processor, UnaryOperator<ExecuteStepDefinition> customizer) Starts an execute step that invokes the given payload processor. -
Uses of ExecuteStepDefinition in io.axoniq.framework.workflow.dsl.simple
Method parameters in io.axoniq.framework.workflow.dsl.simple with type arguments of type ExecuteStepDefinitionModifier and TypeMethodDescriptionSimpleWorkflowContext.execute(String stepName, PayloadProcessor processor, UnaryOperator<ExecuteStepDefinition> customizer) Starts an execute step with an empty step-local input payload and a customized step definition. -
Uses of ExecuteStepDefinition in io.axoniq.framework.workflow.runtime.execution
Methods in io.axoniq.framework.workflow.runtime.execution with parameters of type ExecuteStepDefinitionModifier and TypeMethodDescriptionAbstractWorkflowContext.awaitExecute(ExecuteStepDefinition stepDefinition) AbstractWorkflowContext.execute(ExecuteStepDefinition stepDefinition)