Package | Description |
---|---|
io.simplesource.saga.action.app | |
io.simplesource.saga.action.async | |
io.simplesource.saga.action.eventsourcing | |
io.simplesource.saga.action.http |
Modifier and Type | Method and Description |
---|---|
ActionApp<A> |
ActionApp.withActionProcessor(ActionProcessorBuildStep<A> processorBuildStep)
Adds an action processor build step to the application.
|
Modifier and Type | Method and Description |
---|---|
static <A,D,K,O,R> |
AsyncBuilder.apply(AsyncSpec<A,D,K,O,R> spec) |
static <A,D,K,O,R> |
AsyncBuilder.apply(AsyncSpec<A,D,K,O,R> spec,
ScheduledExecutorService executor) |
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) |
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) |
static <A,D,K,O,R> |
HttpBuilder.apply(HttpSpec<A,D,K,O,R> spec,
ScheduledExecutorService executor) |
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. |
Copyright © 2019. All rights reserved.