Modifier and Type | Method and Description |
---|---|
static <A,D,K,O,R> |
AsyncBuilder.apply(AsyncSpec<A,D,K,O,R> spec,
TopicConfigBuilder.BuildSteps topicBuildFn) |
static <A,D,K,O,R> |
AsyncBuilder.apply(AsyncSpec<A,D,K,O,R> spec,
TopicConfigBuilder.BuildSteps topicBuildFn,
ScheduledExecutorService executor) |
Modifier and Type | Method and Description |
---|---|
static <A,D,K,C> ActionProcessorBuildStep<A> |
EventSourcingBuilder.apply(EventSourcingSpec<A,D,K,C> esSpec,
TopicConfigBuilder.BuildSteps actionTopicBuilder,
TopicConfigBuilder.BuildSteps commandTopicBuilder)
A static function that returns an action processor build step that:
1.
|
Modifier and Type | Method and Description |
---|---|
static <A,D,K,O,R> |
HttpBuilder.apply(HttpSpec<A,D,K,O,R> spec,
TopicConfigBuilder.BuildSteps topicBuildFn) |
static <A,K,B,O,R> |
HttpBuilder.apply(HttpSpec<A,K,B,O,R> httpSpec,
TopicConfigBuilder.BuildSteps topicBuildFn,
ScheduledExecutorService executor)
A static function that delegates the
AsyncBuilder to provide an implementation of an
action processor that can process http web service calls asynchronously as part of a saga. |
Modifier and Type | Method and Description |
---|---|
SagaClientBuilder<A> |
SagaClientBuilder.withTopicConfig(TopicConfigBuilder.BuildSteps topicBuildFn)
Sets the topic configuration for naming and creating the saga request and response topics.
|
Modifier and Type | Method and Description |
---|---|
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(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
|
Modifier and Type | Method and Description |
---|---|
default TopicConfigBuilder.BuildSteps |
TopicConfigBuilder.BuildSteps.withInitialStep(TopicConfigBuilder.BuildSteps initial) |
default TopicConfigBuilder.BuildSteps |
TopicConfigBuilder.BuildSteps.withNextStep(TopicConfigBuilder.BuildSteps initial) |
Modifier and Type | Method and Description |
---|---|
default TopicConfigBuilder.BuildSteps |
TopicConfigBuilder.BuildSteps.withInitialStep(TopicConfigBuilder.BuildSteps initial) |
default TopicConfigBuilder.BuildSteps |
TopicConfigBuilder.BuildSteps.withNextStep(TopicConfigBuilder.BuildSteps initial) |
Copyright © 2019. All rights reserved.