Package com.tnsai.coordination.choreography

Class ChoreographyEngine

java.lang.Object

com.tnsai.coordination.choreography.ChoreographyEngine

public final class ChoreographyEngine
extends Object

Executes a choreography specification using decentralized agent coordination. Each agent reacts to events autonomously based on the declarative spec.

Example usage:

 ChoreographyEngine engine = ChoreographyEngine.builder()
     .spec(spec)
     .agent("validator", validatorAgent)
     .agent("billing", billingAgent)
     .timeout(Duration.ofMinutes(2))
     .build();

 ChoreographyResult result = engine.execute();
 

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	ChoreographyEngine.Builder
static final record	ChoreographyEngine.ChoreographyResult	Result of the entire choreography execution.
static final record	ChoreographyEngine.StepResult	Result of a single interaction step.

Method Summary

Modifier and Type	Method	Description
static ChoreographyEngine.Builder	builder()
ChoreographyEventBus	eventBus()	Returns the event bus (for inspection/testing).
ChoreographyEngine.ChoreographyResult	execute()	Executes the choreography synchronously.
CompletableFuture<ChoreographyEngine.ChoreographyResult>	executeAsync()	Executes the choreography asynchronously.

Methods inherited from class java.lang.Object

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

Method Details

execute

public ChoreographyEngine.ChoreographyResult execute()

Executes the choreography synchronously. Sets up subscriptions based on the spec, fires initial events, and waits for all interactions to complete or timeout.

executeAsync

public CompletableFuture<ChoreographyEngine.ChoreographyResult> executeAsync()

Executes the choreography asynchronously.

eventBus

public ChoreographyEventBus eventBus()

Returns the event bus (for inspection/testing).

builder

public static ChoreographyEngine.Builder builder()