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

Class WaitForDelegate

java.lang.Object

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

io.axoniq.framework.workflow.runtime.execution.WaitForDelegate

All Implemented Interfaces:

WaitForPrimitive

@Internal
public class WaitForDelegate
extends AbstractStepExecutor
implements WaitForPrimitive

Delegate implementing WaitForPrimitive.

Since:

5.4.0

Author:

Stefan Dragisic, Simon Zambrovski

Nested Class Summary

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

WaitForPrimitive.WaitForCommand

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
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.

Method Summary

Modifier and Type	Method	Description
WorkflowStepResult	waitForEvent(WaitForPrimitive.WaitForCommand command)	Wait for event.

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

WaitForDelegate

@Internal
public 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.

Parameters:

workflowExecutionOperations - runtime primitive-operation surface

workflowExecution - workflow state.

runningSteps - running step registry

eventWaitConditions - event wait condition registry

reachedSteps - reached steps tracker

parentEventNameCustomizer - parent event name customizer.

clock - clock for time calculations.

timeoutScheduler - scheduler for workflow step timeouts

unitOfWorkFactory - unit of work factory for creation of new process contexts.

eventSink - event sink to publish events.

executor - executor to offload threads from main thread.

Method Details

waitForEvent

public WorkflowStepResult waitForEvent(WaitForPrimitive.WaitForCommand command)

Description copied from interface: WaitForPrimitive

Wait for event.

Specified by:

waitForEvent in interface WaitForPrimitive

Parameters:

command - command object

Returns:

result of command execution