Package | Description |
---|---|
io.simplesource.saga.saga.app |
Modifier and Type | Method and Description |
---|---|
static <A> SagaApp<A> |
SagaApp.of(SagaSpec<A> sagaSpec,
ActionSpec<A> actionSpec) |
static <A> SagaApp<A> |
SagaApp.of(SagaSpec<A> sagaSpec,
ActionSpec<A> actionSpec,
TopicConfigBuilder.BuildSteps topicBuildFn) |
static <A> SagaApp<A> |
SagaApp.of(SagaSpec<A> sagaSpec,
ActionSpec<A> actionSpec,
TopicConfigBuilder.BuildSteps topicBuildFn,
PropertiesBuilder.BuildSteps propertiesBuildFn)
Static constructor for a
SagaApp saga coordinator application. |
SagaApp<A> |
SagaApp.withAction(String actionType,
TopicConfigBuilder.BuildSteps buildFn)
Adds a single action, specifying the topic configuration for the request and response topics for that action type
|
SagaApp<A> |
SagaApp.withActions(Collection<String> actionTypes,
TopicConfigBuilder.BuildSteps buildFn)
Adds multiple actions, specifying the topic configuration for the request and response topics for all action types
|
SagaApp<A> |
SagaApp.withActions(String... actionTypes)
Adds multiple actions, using default topic configuration
|
SagaApp<A> |
SagaApp.withActions(TopicConfigBuilder.BuildSteps buildFn,
String... actionTypes)
Adds a variable length argument list of action types, specifying the topic configuration for the request and response topics for all action types
|
SagaApp<A> |
SagaApp.withExecutor(ScheduledExecutorService executor)
Sets an executor for the Saga app.
|
SagaApp<A> |
SagaApp.withRetryStrategy(RetryStrategy strategy)
Sets the retry strategy that applies to all action types, unless specifically overridden
|
SagaApp<A> |
SagaApp.withRetryStrategy(String actionType,
RetryStrategy strategy)
Sets the retry strategy for a specific action type
|
Copyright © 2019. All rights reserved.