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

Class PayloadDelegate

java.lang.Object

io.axoniq.framework.workflow.runtime.execution.AbstractStepExecutor

io.axoniq.framework.workflow.runtime.execution.PayloadDelegate

All Implemented Interfaces:

PayloadPrimitive

@Internal
public class PayloadDelegate
extends AbstractStepExecutor
implements PayloadPrimitive

Primitive implementing durable payload modifications.

Since:

5.4.0

Author:

Simon Zambrovski

Nested Class Summary

Nested classes/interfaces inherited from interface io.axoniq.framework.workflow.runtime.api.execution.context.PayloadPrimitive

PayloadPrimitive.ModifyPayloadCommand

Field Summary

Fields inherited from class io.axoniq.framework.workflow.runtime.execution.AbstractStepExecutor

clock, parentEventNameCustomizer, reachedSteps, runningSteps, timeoutScheduler, workflowExecution, workflowExecutionOperations

Constructor Summary

Constructors

Constructor	Description
PayloadDelegate(WorkflowExecutionOperations workflowExecutionOperations, WorkflowExecution workflowExecution, RunningSteps runningSteps, ReachedSteps reachedSteps, EventNameCustomizer parentEventNameCustomizer, Clock clock, WorkflowScheduler timeoutScheduler)	Constructs the primitive implementation.

Method Summary

Modifier and Type	Method	Description
WorkflowStepResult	modifyPayload(PayloadPrimitive.ModifyPayloadCommand command)	Applies payload modification.

Methods inherited from class io.axoniq.framework.workflow.runtime.execution.AbstractStepExecutor

acceptAllPendingTasksForStep, appendEvent, cancelled, cancelled, cancelledWaitForEvent, completed, completed, completedWaitForEvent, eventMessagePayload, failed, getContext, isCancellation, registerParkedStep, registerParkedStep, retrying, retryStarted, sanitize, started, startedWaitForEvent, stateBased, timedOut, timedOut, timedOutWaitForEvent, timedOutWaitForEvent, unwrapCancellation, unwrapCompletionException

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

PayloadDelegate

@Internal
public PayloadDelegate(WorkflowExecutionOperations workflowExecutionOperations,
 WorkflowExecution workflowExecution,
 RunningSteps runningSteps,
 ReachedSteps reachedSteps,
 EventNameCustomizer parentEventNameCustomizer,
 Clock clock,
 WorkflowScheduler timeoutScheduler)

Constructs the primitive implementation.

Parameters:

workflowExecutionOperations - runtime primitive-operation surface

workflowExecution - workflow execution

runningSteps - running step registry

reachedSteps - reached steps tracker

parentEventNameCustomizer - parent event name customizer

clock - clock for time calculations

timeoutScheduler - scheduler for step timeouts

Method Details

modifyPayload

public WorkflowStepResult modifyPayload(PayloadPrimitive.ModifyPayloadCommand command)

Description copied from interface: PayloadPrimitive

Applies payload modification.

Specified by:

modifyPayload in interface PayloadPrimitive

Parameters:

command - command object for the primitive.

Returns:

durable result handle.