public class InMemorySagaCoordinator extends Object implements CamelSagaCoordinator
| Constructor and Description |
|---|
InMemorySagaCoordinator(CamelContext camelContext,
InMemorySagaService sagaService,
String sagaId) |
| Modifier and Type | Method and Description |
|---|---|
CompletableFuture<Void> |
beginStep(Exchange exchange,
CamelSagaStep step) |
CompletableFuture<Void> |
compensate() |
CompletableFuture<Void> |
complete() |
CompletableFuture<Boolean> |
doCompensate() |
CompletableFuture<Boolean> |
doComplete() |
CompletableFuture<Boolean> |
doFinalize(Function<CamelSagaStep,Optional<Endpoint>> endpointExtractor,
String description) |
String |
getId()
Returns the id
|
public InMemorySagaCoordinator(CamelContext camelContext, InMemorySagaService sagaService, String sagaId)
public CompletableFuture<Void> beginStep(Exchange exchange, CamelSagaStep step)
beginStep in interface CamelSagaCoordinatorpublic CompletableFuture<Void> compensate()
compensate in interface CamelSagaCoordinatorpublic CompletableFuture<Void> complete()
complete in interface CamelSagaCoordinatorpublic CompletableFuture<Boolean> doCompensate()
public CompletableFuture<Boolean> doComplete()
public CompletableFuture<Boolean> doFinalize(Function<CamelSagaStep,Optional<Endpoint>> endpointExtractor, String description)
Apache Camel