Uses of Interface
io.axoniq.framework.workflow.dsl.api.EventNameCustomizer
Packages that use EventNameCustomizer
Package
Description
Package containing workflow configuration components.
Internal runtime contracts for workflow execution, command dispatch, configuration, and event publication.
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.Internal runtime utilities for future resolution, workflow event and metadata construction, processing context
propagation, reflection, and workflow state inspection.
-
Uses of EventNameCustomizer in io.axoniq.framework.workflow.configuration
Fields in io.axoniq.framework.workflow.configuration declared as EventNameCustomizerModifier and TypeFieldDescriptionprotected EventNameCustomizerWorkflowCustomization.eventNameCustomizerMethods in io.axoniq.framework.workflow.configuration with parameters of type EventNameCustomizerModifier and TypeMethodDescriptionWorkflowCustomization.eventNameCustomizer(EventNameCustomizer eventNameCustomizer) Sets event name customizer. -
Uses of EventNameCustomizer in io.axoniq.framework.workflow.dsl.api
Methods in io.axoniq.framework.workflow.dsl.api that return EventNameCustomizerModifier and TypeMethodDescriptionPrimitiveMetadata.eventNameCustomizer()Returns the value of theeventNameCustomizerrecord component.EventNameCustomizer.forStepInheritance()Returns a customized event name based on the provided step name, parameters, and workflow status.Methods in io.axoniq.framework.workflow.dsl.api with parameters of type EventNameCustomizerModifier and TypeMethodDescriptionCancelStepDefinition.eventNameCustomizer(EventNameCustomizer eventNameCustomizer) Returns a copy of this definition with the provided event name customizer.CancelWorkflowDefinition.eventNameCustomizer(EventNameCustomizer eventNameCustomizer) Returns a copy of this definition with the provided event name customizer.ExecuteStepDefinition.eventNameCustomizer(EventNameCustomizer eventNameCustomizer) Returns a copy of this definition with the provided event name customizer.FailWorkflowDefinition.eventNameCustomizer(EventNameCustomizer eventNameCustomizer) Returns a copy of this definition with the provided event name customizer.PayloadStepDefinition.eventNameCustomizer(EventNameCustomizer eventNameCustomizer) Returns a copy of this definition with the provided event name customizer.PrimitiveMetadata.eventNameCustomizer(EventNameCustomizer eventNameCustomizer) Returns a copy of this metadata with the provided event name customizer.VersionStepDefinition.eventNameCustomizer(EventNameCustomizer eventNameCustomizer) Returns a copy of this definition with the provided event name customizer.WaitForStepDefinition.eventNameCustomizer(EventNameCustomizer eventNameCustomizer) Returns a copy of this definition with the provided event name customizer.Constructors in io.axoniq.framework.workflow.dsl.api with parameters of type EventNameCustomizerModifierConstructorDescriptionPrimitiveMetadata(String stepName, EventNameCustomizer eventNameCustomizer) Creates an instance of aPrimitiveMetadatarecord class. -
Uses of EventNameCustomizer in io.axoniq.framework.workflow.runtime.api.execution.context
Methods in io.axoniq.framework.workflow.runtime.api.execution.context that return EventNameCustomizerModifier and TypeMethodDescriptionExecutePrimitive.ExecuteCommand.eventNameCustomizer()Returns event name customizer.PayloadPrimitive.ModifyPayloadCommand.eventNameCustomizer()Retrieves event name customizer for the step.PrimitiveCommands.SimpleVersionCommand.eventNameCustomizer()Returns the value of theeventNameCustomizerrecord component.PrimitiveCommands.WorkflowStepResultExecuteCommand.eventNameCustomizer()Returns the value of theeventNameCustomizerrecord component.PrimitiveCommands.WorkflowStepResultModifyPayloadCommand.eventNameCustomizer()Returns the value of theeventNameCustomizerrecord component.PrimitiveCommands.WorkflowStepResultWaitForCommand.eventNameCustomizer()Returns the value of theeventNameCustomizerrecord component.VersionPrimitive.VersionCommand.eventNameCustomizer()Event name customizer used to produce the wire-level name of the migration step event.WaitForPrimitive.WaitForCommand.eventNameCustomizer()Event name customizerWorkflowConfiguration.eventNameCustomizer()Default event name customizer applied on workflow level.WorkflowLifecycleControl.CancelStepCommand.eventNameCustomizer()Returns the customizer for published event names.WorkflowLifecycleControl.CancelWorkflowCommand.eventNameCustomizer()Returns the customizer for published event names.WorkflowLifecycleControl.FailWorkflowCommand.eventNameCustomizer()Returns the customizer for published event names.Methods in io.axoniq.framework.workflow.runtime.api.execution.context with parameters of type EventNameCustomizerModifier and TypeMethodDescriptionPrimitiveCommands.cancelStep(String stepName, @Nullable Throwable cause, EventNameCustomizer eventNameCustomizer) Creates a command cancelling one running step.PrimitiveCommands.cancelWorkflow(@Nullable Throwable cause, EventNameCustomizer eventNameCustomizer) Creates a command cancelling an entire workflow.PrimitiveCommands.failWorkflow(@Nullable Throwable cause, EventNameCustomizer eventNameCustomizer) Creates a command failing an entire workflow.PrimitiveCommands.modifyPayload(String stepName, PayloadModification payloadModification, EventNameCustomizer eventNameCustomizer) Factory method to create aPrimitiveCommands.WorkflowStepResultModifyPayloadCommand.PrimitiveCommands.version(String stepName, String newVersion, EventNameCustomizer eventNameCustomizer) Factory method to create aPrimitiveCommands.SimpleVersionCommand.PrimitiveCommands.waitForEvent(String stepName, EventCondition eventCondition, PayloadReducer resultPayloadReducer, Duration duration, EventNameCustomizer eventNameCustomizer) Factory method to create aPrimitiveCommands.WorkflowStepResultWaitForCommand.Constructors in io.axoniq.framework.workflow.runtime.api.execution.context with parameters of type EventNameCustomizerModifierConstructorDescriptionSimpleVersionCommand(String stepName, String newVersion, EventNameCustomizer eventNameCustomizer) Creates an instance of aSimpleVersionCommandrecord class.WorkflowStepResultExecuteCommand(String stepName, Map<String, @Nullable Object> local, PayloadProcessor action, PayloadReducer parameterMapping, PayloadReducer resultMapping, Duration timeout, EventNameCustomizer eventNameCustomizer, RetryPolicy retryPolicy) Creates an instance of aWorkflowStepResultExecuteCommandrecord class.WorkflowStepResultModifyPayloadCommand(String stepName, PayloadModification payloadModification, EventNameCustomizer eventNameCustomizer) Creates an instance of aWorkflowStepResultModifyPayloadCommandrecord class.WorkflowStepResultWaitForCommand(String stepName, EventCondition eventCondition, PayloadReducer resultPayloadReducer, Duration timeout, EventNameCustomizer eventNameCustomizer) Creates an instance of aWorkflowStepResultWaitForCommandrecord class. -
Uses of EventNameCustomizer in io.axoniq.framework.workflow.runtime.execution
Classes in io.axoniq.framework.workflow.runtime.execution that implement EventNameCustomizerModifier and TypeClassDescriptionclassDefault implementation ofEventNameCustomizerthat builds event names from a base name and status suffix.Fields in io.axoniq.framework.workflow.runtime.execution declared as EventNameCustomizerModifier and TypeFieldDescriptionprotected final EventNameCustomizerAbstractStepExecutor.parentEventNameCustomizerMethods in io.axoniq.framework.workflow.runtime.execution that return EventNameCustomizerModifier and TypeMethodDescriptionDefaultEventNameCustomizer.forStepInheritance()static EventNameCustomizerDefaultEventNameCustomizer.Builder.merge(EventNameCustomizer parent, EventNameCustomizer child) Merges two customizers into one.Methods in io.axoniq.framework.workflow.runtime.execution with parameters of type EventNameCustomizerModifier and TypeMethodDescriptionprotected CompletableFuture<Void> AbstractStepExecutor.cancelled(String stepName, EventNameCustomizer eventNameCustomizer) protected CompletableFuture<Void> AbstractStepExecutor.cancelled(String stepName, @Nullable Throwable cause, EventNameCustomizer eventNameCustomizer) protected CompletableFuture<Void> AbstractStepExecutor.cancelledWaitForEvent(String stepName, @Nullable Throwable cause, EventNameCustomizer eventNameCustomizer) protected CompletableFuture<Void> AbstractStepExecutor.completed(String stepName, Map<String, @Nullable Object> payload, EventNameCustomizer eventNameCustomizer) protected CompletableFuture<Void> AbstractStepExecutor.completed(String stepName, Map<String, @Nullable Object> payload, @Nullable String payloadReducerName, EventNameCustomizer eventNameCustomizer) protected CompletableFuture<Void> AbstractStepExecutor.completedWaitForEvent(String stepName, Map<String, @Nullable Object> payload, @Nullable String payloadReducerName, EventNameCustomizer eventNameCustomizer) protected CompletableFuture<Void> AbstractStepExecutor.failed(String stepName, Throwable ex, EventNameCustomizer eventNameCustomizer) static EventNameCustomizerDefaultEventNameCustomizer.Builder.merge(EventNameCustomizer parent, EventNameCustomizer child) Merges two customizers into one.protected voidAbstractStepExecutor.registerParkedStep(String stepName, CompletableFuture<?> parkedPhase, EventNameCustomizer eventNameCustomizer, Runnable onCancelled) Registers the given future as the step's running phase while the step is parked (a wait timeout window, a retry backoff window).protected voidAbstractStepExecutor.registerParkedStep(String stepName, CompletableFuture<?> parkedPhase, Runnable cancelTimer, EventNameCustomizer eventNameCustomizer, Runnable onCancelled) Registers a parked step and owns the lifetime of its timer.protected CompletableFuture<Void> AbstractStepExecutor.retrying(String stepName, StepRetryInfo retryInfo, EventNameCustomizer eventNameCustomizer) protected CompletableFuture<Void> AbstractStepExecutor.retryStarted(String stepName, StepRetryInfo retryInfo, EventNameCustomizer eventNameCustomizer) protected CompletableFuture<Void> AbstractStepExecutor.started(String stepName, Map<String, @Nullable Object> payload, EventNameCustomizer eventNameCustomizer) protected CompletableFuture<Void> AbstractStepExecutor.startedWaitForEvent(String stepName, Map<String, @Nullable Object> payload, EventNameCustomizer eventNameCustomizer) static WorkflowStepResultAbstractStepExecutor.stateBased(String stepName, EventNameCustomizer eventNameCustomizer, WorkflowExecution workflowExecution) Creates a durable result handle for a step while retaining its event-name customizer for later cancellation.protected CompletableFuture<Void> AbstractStepExecutor.timedOut(String stepName, EventNameCustomizer eventNameCustomizer) protected CompletableFuture<Void> AbstractStepExecutor.timedOut(String stepName, Instant timeoutTimestamp, EventNameCustomizer eventNameCustomizer) protected CompletableFuture<Void> AbstractStepExecutor.timedOutWaitForEvent(String stepName, EventNameCustomizer eventNameCustomizer) protected CompletableFuture<Void> AbstractStepExecutor.timedOutWaitForEvent(String stepName, Instant timeoutTimestamp, EventNameCustomizer eventNameCustomizer) Constructors in io.axoniq.framework.workflow.runtime.execution with parameters of type EventNameCustomizerModifierConstructorDescriptionAbstractStepExecutor(WorkflowExecutionOperations workflowExecutionOperations, WorkflowExecution workflowExecution, RunningSteps runningSteps, ReachedSteps reachedSteps, EventNameCustomizer parentEventNameCustomizer, Clock clock, WorkflowScheduler timeoutScheduler) Constructs the abstract step executor.ExecuteDelegate(WorkflowExecutionOperations workflowExecutionOperations, WorkflowExecution workflowExecution, RunningSteps runningSteps, ReachedSteps reachedSteps, EventNameCustomizer parentEventNameCustomizer, Clock clock, UnitOfWorkFactory unitOfWorkFactory, Executor executor, WorkflowScheduler timeoutScheduler, ExecuteStepActionResolver actionResolver) Constructs the delegate.PayloadDelegate(WorkflowExecutionOperations workflowExecutionOperations, WorkflowExecution workflowExecution, RunningSteps runningSteps, ReachedSteps reachedSteps, EventNameCustomizer parentEventNameCustomizer, Clock clock, WorkflowScheduler timeoutScheduler) Constructs the primitive implementation.RetryableExecuteDelegate(ExecuteDelegate delegate, WorkflowExecutionOperations workflowExecutionOperations, WorkflowExecution workflowExecution, RunningSteps runningSteps, ReachedSteps reachedSteps, EventNameCustomizer parentEventNameCustomizer, Clock clock, WorkflowScheduler timeoutScheduler) Constructs the delegate.VersionDelegate(WorkflowExecutionOperations workflowExecutionOperations, WorkflowExecution workflowExecution, ReachedSteps reachedSteps, EventNameCustomizer parentEventNameCustomizer, Clock clock) Constructs the delegate.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. -
Uses of EventNameCustomizer in io.axoniq.framework.workflow.runtime.util
Methods in io.axoniq.framework.workflow.runtime.util with parameters of type EventNameCustomizerModifier and TypeMethodDescriptionstatic EventMessageEventMessageUtils.cancelledStep(WorkflowEventPublicationContext workflowEventPublicationContext, String stepName, EventNameCustomizer customizer) Creates a new event message stating that a workflow step has been cancelled.static EventMessageEventMessageUtils.cancelledStep(WorkflowEventPublicationContext workflowEventPublicationContext, String stepName, @Nullable Throwable cause, EventNameCustomizer customizer) Creates a new event message stating that a workflow step has been cancelled, optionally with a cause.static EventMessageEventMessageUtils.cancelledWaitForEventStep(WorkflowEventPublicationContext workflowEventPublicationContext, String stepName, @Nullable Throwable cause, EventNameCustomizer customizer) Creates a cancelled event for a wait-for-event step.static EventMessageEventMessageUtils.cancelledWorkflow(WorkflowEventPublicationContext workflowEventPublicationContext, String workflowName, @Nullable Throwable cause, VersionedType workflowDefinitionId, EventNameCustomizer customizer) static EventMessageEventMessageUtils.cancelledWorkflow(WorkflowEventPublicationContext workflowEventPublicationContext, String workflowName, VersionedType workflowDefinitionId, EventNameCustomizer customizer) Creates a new event message stating that a workflow has been cancelled.static EventMessageEventMessageUtils.completedStep(WorkflowEventPublicationContext workflowEventPublicationContext, String stepName, Map<String, @Nullable Object> result, @Nullable String resultPayloadReducerName, EventNameCustomizer customizer) Creates a new event message stating that a workflow step has completed.static EventMessageEventMessageUtils.completedWaitForEventStep(WorkflowEventPublicationContext workflowEventPublicationContext, String stepName, Map<String, @Nullable Object> result, @Nullable String resultPayloadReducerName, EventNameCustomizer customizer) Creates a completed event for a wait-for-event step.static EventMessageEventMessageUtils.completedWorkflow(WorkflowEventPublicationContext workflowEventPublicationContext, String workflowName, VersionedType workflowDefinitionId, EventNameCustomizer customizer) Creates a new event message stating that a workflow has completed successfully.static EventMessageEventMessageUtils.failedWorkflow(WorkflowEventPublicationContext workflowEventPublicationContext, String workflowName, Exception exception, VersionedType workflowDefinitionId, EventNameCustomizer customizer) Creates a new event message stating that a workflow has failed.static EventMessageEventMessageUtils.failStep(WorkflowEventPublicationContext workflowEventPublicationContext, String stepName, Throwable exception, EventNameCustomizer customizer) Creates a new event message stating that a workflow step has failed.static EventMessageEventMessageUtils.retryingStep(WorkflowEventPublicationContext workflowEventPublicationContext, String stepName, StepRetryInfo retryInfo, EventNameCustomizer customizer) Creates a new event message stating that a workflow step is retrying.static EventMessageEventMessageUtils.retryStartedStep(WorkflowEventPublicationContext workflowEventPublicationContext, String stepName, StepRetryInfo retryInfo, EventNameCustomizer customizer) Creates a new event message stating that a retry attempt of a workflow step has started.static EventMessageEventMessageUtils.startedStep(WorkflowEventPublicationContext workflowEventPublicationContext, String stepName, Map<String, @Nullable Object> local, EventNameCustomizer customizer) Creates a new event message stating that a workflow step has started.static EventMessageEventMessageUtils.startedWaitForEventStep(WorkflowEventPublicationContext workflowEventPublicationContext, String stepName, Map<String, @Nullable Object> local, EventNameCustomizer customizer) Creates a new started event for a wait-for-event step.static EventMessageEventMessageUtils.startedWorkflow(WorkflowEventPublicationContext workflowEventPublicationContext, String workflowName, VersionedType workflowDefinitionId, EventNameCustomizer customizer) Creates a new event message stating that a workflow has started.static EventMessageEventMessageUtils.timeoutStep(WorkflowEventPublicationContext workflowEventPublicationContext, String stepName, Instant time, EventNameCustomizer customizer) Creates a new event message stating that a workflow step has timed out.static EventMessageEventMessageUtils.timeoutWaitForEventStep(WorkflowEventPublicationContext workflowEventPublicationContext, String stepName, Instant time, EventNameCustomizer customizer) Creates a timed-out event for a wait-for-event step.static EventMessageEventMessageUtils.timeoutWorkflow(WorkflowEventPublicationContext workflowEventPublicationContext, String workflowName, Instant time, VersionedType workflowDefinitionId, EventNameCustomizer customizer) Creates a new event message stating that a workflow has timed out.static EventMessageEventMessageUtils.versionMigrationStep(WorkflowEventPublicationContext workflowEventPublicationContext, String changeId, String version, EventNameCustomizer customizer) Creates a new event message recording a migration step for the givenchangeId.