Package akka.javasdk.workflow

Class Workflow.WorkflowSettingsBuilder

Object

akka.javasdk.workflow.Workflow.WorkflowSettingsBuilder

Enclosing class:

Workflow<S>

public static class Workflow.WorkflowSettingsBuilder
extends Object

Constructor Summary

Constructors

Constructor	Description
WorkflowSettingsBuilder(Optional<Duration> defaultStepTimeout, Optional<Workflow.RecoverStrategy<?>> defaultStepRecoverStrategy, Map<String,Workflow.StepSettings> stepSettingsMap)

Method Summary

Modifier and Type	Method	Description
Workflow.WorkflowSettings	build()	Creates the final workflow configuration from this builder.
Workflow.WorkflowSettingsBuilder	defaultStepRecovery(Workflow.RecoverStrategy<?> recoverStrategy)	Define a default recovery strategy for all steps.
Workflow.WorkflowSettingsBuilder	defaultStepTimeout(Duration timeout)	Define a default timeout duration for all steps.
static Workflow.WorkflowSettingsBuilder	newBuilder()
<W> Workflow.WorkflowSettingsBuilder	stepRecovery(akka.japi.function.Function<W,Workflow.StepEffect> lambda, Workflow.RecoverStrategy<?> recovery)	Configure a specific step with a recovery strategy.
<W, I> Workflow.WorkflowSettingsBuilder	stepRecovery(akka.japi.function.Function2<W,I,Workflow.StepEffect> lambda, Workflow.RecoverStrategy<?> recovery)	Configure a specific step with a recovery strategy.
<W> Workflow.WorkflowSettingsBuilder	stepTimeout(akka.japi.function.Function<W,Workflow.StepEffect> lambda, Duration timeout)	Configure a specific step with a timeout.
<W, I> Workflow.WorkflowSettingsBuilder	stepTimeout(akka.japi.function.Function2<W,I,Workflow.StepEffect> lambda, Duration timeout)	Configure a specific step with a timeout.

Methods inherited from class java.lang.Object

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

Constructor Details

WorkflowSettingsBuilder

public WorkflowSettingsBuilder(Optional<Duration> defaultStepTimeout,
 Optional<Workflow.RecoverStrategy<?>> defaultStepRecoverStrategy,
 Map<String,Workflow.StepSettings> stepSettingsMap)

Method Details

newBuilder

public static Workflow.WorkflowSettingsBuilder newBuilder()

defaultStepTimeout

public Workflow.WorkflowSettingsBuilder defaultStepTimeout(Duration timeout)

Define a default timeout duration for all steps. Can be overridden per step.

defaultStepRecovery

public Workflow.WorkflowSettingsBuilder defaultStepRecovery(Workflow.RecoverStrategy<?> recoverStrategy)

Define a default recovery strategy for all steps. Can be overridden per step.

stepTimeout

public <W> Workflow.WorkflowSettingsBuilder stepTimeout(akka.japi.function.Function<W,Workflow.StepEffect> lambda,
 Duration timeout)

Configure a specific step with a timeout.

Parameters:

lambda - Reference to the step method

timeout - Timeout duration for this step

stepTimeout

public <W,
I> Workflow.WorkflowSettingsBuilder stepTimeout(akka.japi.function.Function2<W,I,Workflow.StepEffect> lambda,
 Duration timeout)

Configure a specific step with a timeout.

Parameters:

lambda - Reference to the step method

timeout - Timeout duration for this step

stepRecovery

public <W> Workflow.WorkflowSettingsBuilder stepRecovery(akka.japi.function.Function<W,Workflow.StepEffect> lambda,
 Workflow.RecoverStrategy<?> recovery)

Configure a specific step with a recovery strategy.

Parameters:

lambda - Reference to the step method

recovery - Recovery strategy for this step

stepRecovery

public <W,
I> Workflow.WorkflowSettingsBuilder stepRecovery(akka.japi.function.Function2<W,I,Workflow.StepEffect> lambda,
 Workflow.RecoverStrategy<?> recovery)

Configure a specific step with a recovery strategy.

Parameters:

lambda - Reference to the step method

recovery - Recovery strategy for this step

build

public Workflow.WorkflowSettings build()

Creates the final workflow configuration from this builder.

Returns:

The complete workflow configuration