Package app.ductape.sdk.warehouse.transactions

Class WarehouseSagaOrchestrator

java.lang.Object

app.ductape.sdk.warehouse.transactions.WarehouseSagaOrchestrator

public final class WarehouseSagaOrchestrator
extends Object

TS parity: sdk/ts/src/warehouse/transactions/saga-orchestrator.ts (synchronous).

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	WarehouseSagaOrchestrator.StepExecutor

Field Summary

Fields

Modifier and Type	Field	Description
static final String	STATE_ERROR_MESSAGE
static final String	STATE_ID
static final String	STATE_ON_FAILURE
static final String	STATE_ROLLBACK_STEPS
static final String	STATE_STARTED_AT
static final String	STATE_STATUS
static final String	STATE_STEP_RESULTS

Constructor Summary

Constructors

Constructor	Description
WarehouseSagaOrchestrator(WarehouseSagaOrchestrator.StepExecutor executor, Long defaultTimeoutMs)
WarehouseSagaOrchestrator(WarehouseSagaOrchestrator.StepExecutor executor, Long defaultTimeoutMs, WarehouseTypes.SagaStateHooks sagaHooks)

Method Summary

Modifier and Type	Method	Description
Map<String,Object>	execute(Map<String,Object> mainOperation, Map<String,Object> transaction)
Map<String,Object>	getState(String sagaId)	TS getState(sagaId) — snapshot from the in-flight saga only (cleared when execute finishes).
Map<String,Object>	resume(String sagaId)	TS parity: resume(sagaId) — compensating runs persisted rollback steps; terminal statuses return a result-shaped map; executing returns loaded snapshot (TS simplified path).

Methods inherited from class java.lang.Object

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

Field Details

STATE_ID

public static final String STATE_ID

See Also:

• Constant Field Values

STATE_STATUS

public static final String STATE_STATUS

See Also:

• Constant Field Values

STATE_STEP_RESULTS

public static final String STATE_STEP_RESULTS

See Also:

• Constant Field Values

STATE_STARTED_AT

public static final String STATE_STARTED_AT

See Also:

• Constant Field Values

STATE_ROLLBACK_STEPS

public static final String STATE_ROLLBACK_STEPS

See Also:

• Constant Field Values

STATE_ON_FAILURE

public static final String STATE_ON_FAILURE

See Also:

• Constant Field Values

STATE_ERROR_MESSAGE

public static final String STATE_ERROR_MESSAGE

See Also:

• Constant Field Values

Constructor Details

WarehouseSagaOrchestrator

public WarehouseSagaOrchestrator(WarehouseSagaOrchestrator.StepExecutor executor,
 Long defaultTimeoutMs)

WarehouseSagaOrchestrator

public WarehouseSagaOrchestrator(WarehouseSagaOrchestrator.StepExecutor executor,
 Long defaultTimeoutMs,
 WarehouseTypes.SagaStateHooks sagaHooks)

Method Details

getState

public Map<String,Object> getState(String sagaId)

TS getState(sagaId) — snapshot from the in-flight saga only (cleared when execute finishes).

resume

public Map<String,Object> resume(String sagaId)

TS parity: resume(sagaId) — compensating runs persisted rollback steps; terminal statuses return a result-shaped map; executing returns loaded snapshot (TS simplified path).

execute

public Map<String,Object> execute(Map<String,Object> mainOperation,
 Map<String,Object> transaction)