Uses of Interface
io.axoniq.framework.workflow.dsl.api.PayloadProcessor

Packages that use PayloadProcessor

Package	Description
io.axoniq.framework.workflow.dsl.api
io.axoniq.framework.workflow.dsl.base	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.
io.axoniq.framework.workflow.dsl.simple	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.
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 PayloadProcessor in io.axoniq.framework.workflow.dsl.api

Methods in io.axoniq.framework.workflow.dsl.api that return PayloadProcessor

Modifier and Type	Method	Description
PayloadProcessor	ExecuteStepDefinition.action()	Returns the value of the action record component.

Methods in io.axoniq.framework.workflow.dsl.api with parameters of type PayloadProcessor

Modifier and Type	Method	Description
ExecuteStepDefinition	ExecuteStepDefinition.action(PayloadProcessor action)	Returns a copy of this definition with the provided action.

Constructors in io.axoniq.framework.workflow.dsl.api with parameters of type PayloadProcessor

Modifier	Constructor	Description
	ExecuteStepDefinition(PrimitiveMetadata primitiveMetadata, Map<String,@Nullable Object> inputPayload, PayloadProcessor action, PayloadMapping payloadMapping, Timing timing, RetryPolicy retryPolicy)	Creates an instance of a ExecuteStepDefinition record class.

Uses of PayloadProcessor in io.axoniq.framework.workflow.dsl.base

Methods in io.axoniq.framework.workflow.dsl.base with parameters of type PayloadProcessor

Modifier and Type	Method	Description
Map<String,@Nullable Object>	BaseWorkflowContext.awaitExecute(String stepName, Map<String,@Nullable Object> inputPayload, PayloadProcessor processor)	Starts an execute step with default settings and blocks until it completes.
Map<String,@Nullable Object>	BaseWorkflowContext.awaitExecute(String stepName, Map<String,@Nullable Object> inputPayload, PayloadProcessor processor, UnaryOperator<ExecuteStepDefinition> customizer)	Starts an execute step and blocks until it completes.
ExecuteStepDefinition	BaseWorkflowContext.defaultExecuteStepDefinition(String stepName, Map<String,@Nullable Object> inputPayload, PayloadProcessor processor)	Creates the default execute step definition used by the convenience overloads in this class.
WorkflowStepResult	BaseWorkflowContext.execute(String stepName, Map<String,@Nullable Object> inputPayload, PayloadProcessor processor)	Starts an execute step with the default step definition settings.
WorkflowStepResult	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 PayloadProcessor in io.axoniq.framework.workflow.dsl.simple

Methods in io.axoniq.framework.workflow.dsl.simple with parameters of type PayloadProcessor

Modifier and Type	Method	Description
WorkflowStepResult	SimpleWorkflowContext.execute(String stepName, PayloadProcessor processor)	Starts an execute step with an empty step-local input payload.
WorkflowStepResult	SimpleWorkflowContext.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 PayloadProcessor in io.axoniq.framework.workflow.runtime.api.execution.context

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

Modifier and Type	Method	Description
PayloadProcessor	ExecutePrimitive.ExecuteCommand.action()	Returns action to be executed.
PayloadProcessor	PrimitiveCommands.WorkflowStepResultExecuteCommand.action()	Returns the value of the action record component.

Constructors in io.axoniq.framework.workflow.runtime.api.execution.context with parameters of type PayloadProcessor

Modifier	Constructor	Description
	WorkflowStepResultExecuteCommand(String stepName, Map<String,@Nullable Object> local, PayloadProcessor action, PayloadReducer parameterMapping, PayloadReducer resultMapping, Duration timeout, EventNameCustomizer eventNameCustomizer, RetryPolicy retryPolicy)	Creates an instance of a WorkflowStepResultExecuteCommand record class.

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

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

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.

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

Methods in io.axoniq.framework.workflow.runtime.test.fixture with parameters of type PayloadProcessor

Modifier and Type	Method	Description
SELF	GivenWhen.execute(String stepName, PayloadProcessor payloadProcessor)	Supplies a fake action for an execute step and waits until the step reaches a terminal state.
void	DefaultWorkflowTestDriver.executeStep(String stepName, PayloadProcessor payloadProcessor)
void	WorkflowTestDriver.executeStep(String stepName, PayloadProcessor payloadProcessor)	Waits until the given step is executed calling the given payload processor.

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

Methods in io.axoniq.framework.workflow.runtime.test.utils that return PayloadProcessor

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.

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

Modifier and Type	Method	Description
void	ManualExecuteStepActionResolver.applyAction(String stepName, PayloadProcessor action)	Applies the supplied action for the step instead of the workflow-defined action.