Package com.tnsai.coordination.workflow

Class SagaExecutor

java.lang.Object

com.tnsai.coordination.workflow.SagaExecutor

public final class SagaExecutor
extends Object

Executes workflow steps as a Saga with compensation (rollback) support. Steps run sequentially; if any step fails, compensation actions are executed in reverse order for all previously completed steps.

Example usage:

 Agent bookFlight = ...;
 Agent cancelFlight = ...;
 Agent bookHotel = ...;
 Agent cancelHotel = ...;

 WorkflowResult result = SagaExecutor.builder()
     .step(WorkflowStep.of("book-flight", bookFlight)
         .withCompensation(WorkflowStep.of("cancel-flight", cancelFlight)))
     .step(WorkflowStep.of("book-hotel", bookHotel)
         .withCompensation(WorkflowStep.of("cancel-hotel", cancelHotel)))
     .step(WorkflowStep.of("confirm", confirmAgent))
     .build()
     .execute(new WorkflowContext("saga-1"));
 

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	SagaExecutor.Builder

Method Summary

Modifier and Type	Method	Description
static SagaExecutor.Builder	builder()
WorkflowResult	execute(WorkflowContext context)	Executes all steps sequentially.
CompletableFuture<WorkflowResult>	executeAsync(WorkflowContext context)	Executes the saga asynchronously.

Methods inherited from class java.lang.Object

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

Method Details

execute

public WorkflowResult execute(WorkflowContext context)

Executes all steps sequentially. On failure, compensates completed steps in reverse order.

executeAsync

public CompletableFuture<WorkflowResult> executeAsync(WorkflowContext context)

Executes the saga asynchronously.

builder

public static SagaExecutor.Builder builder()