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

Class ExecuteDelegate

java.lang.Object

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

io.axoniq.framework.workflow.runtime.execution.ExecuteDelegate

All Implemented Interfaces:

ExecutePrimitive

@Internal
public class ExecuteDelegate
extends AbstractStepExecutor
implements ExecutePrimitive

Execute delegate implementing ExecutePrimitive.

Since:

5.4.0

Author:

Allard Buijze, Simon Zambrovski, Stefan Dragisic, Steven van Beelen

Nested Class Summary

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

ExecutePrimitive.ExecuteCommand

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
ExecuteDelegate(WorkflowExecutionOperations workflowExecutionOperations, WorkflowExecution workflowExecution, RunningSteps runningSteps, ReachedSteps reachedSteps, EventNameCustomizer parentEventNameCustomizer, Clock clock, UnitOfWorkFactory unitOfWorkFactory, Executor executor, WorkflowScheduler timeoutScheduler, ExecuteStepActionResolver actionResolver)	Constructs the delegate.

Method Summary

Modifier and Type	Method	Description
WorkflowStepResult	execute(ExecutePrimitive.ExecuteCommand command)	Execute primitive.

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

ExecuteDelegate

@Internal
public ExecuteDelegate(WorkflowExecutionOperations workflowExecutionOperations,
 WorkflowExecution workflowExecution,
 RunningSteps runningSteps,
 ReachedSteps reachedSteps,
 EventNameCustomizer parentEventNameCustomizer,
 Clock clock,
 UnitOfWorkFactory unitOfWorkFactory,
 Executor executor,
 WorkflowScheduler timeoutScheduler,
 ExecuteStepActionResolver actionResolver)

Constructs the delegate.

Parameters:

workflowExecutionOperations - runtime operations for the workflow execution

workflowExecution - workflow state

runningSteps - running step registry

reachedSteps - reached steps tracker

parentEventNameCustomizer - event name customizer

clock - clock for time calculations

unitOfWorkFactory - unit of work factory for creation of new processing contexts

executor - executor to offload execution tasks from workflow thread

timeoutScheduler - scheduler for workflow step timeouts

actionResolver - resolver for execute step actions

Method Details

execute

public WorkflowStepResult execute(ExecutePrimitive.ExecuteCommand command)

Description copied from interface: ExecutePrimitive

Execute primitive.

Specified by:

execute in interface ExecutePrimitive

Parameters:

command - command object for the primitive.

Returns:

durable result handle.