io.simplesource.saga.action.async

Class AsyncBuilder

java.lang.Object

io.simplesource.saga.action.async.AsyncBuilder

public final class AsyncBuilder
extends Object

A class with a single static function that returns an action processor build step for an async action.

An async action is an action that executes an arbitrary asynchronous function in a saga. The result of the function can be optionally piped to an output topic.

This build step:

1. Defines the stream topology for the Async processor
2. Creates producers and consumers that handle the asynchronous invocation
3. Resolves the topic configuration (names and configuration properties)
4. Handles cleans up of resources when the stream terminates

Constructor Summary

Constructors

Constructor and Description
AsyncBuilder()

Method Summary

Modifier and Type	Method and Description
static <A,D,K,O,R> ActionProcessorBuildStep<A>	apply(AsyncSpec<A,D,K,O,R> spec)
static <A,D,K,O,R> ActionProcessorBuildStep<A>	apply(AsyncSpec<A,D,K,O,R> spec, ScheduledExecutorService executor)
static <A,D,K,O,R> ActionProcessorBuildStep<A>	apply(AsyncSpec<A,D,K,O,R> spec, TopicConfigBuilder.BuildSteps topicBuildFn)
static <A,D,K,O,R> ActionProcessorBuildStep<A>	apply(AsyncSpec<A,D,K,O,R> spec, TopicConfigBuilder.BuildSteps topicBuildFn, ScheduledExecutorService executor)

Methods inherited from class java.lang.Object

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

Constructor Detail

AsyncBuilder

public AsyncBuilder()

Method Detail

apply

public static <A,D,K,O,R> ActionProcessorBuildStep<A> apply(AsyncSpec<A,D,K,O,R> spec,
                                                            TopicConfigBuilder.BuildSteps topicBuildFn,
                                                            ScheduledExecutorService executor)

Type Parameters:

A - common representation form for all action commands (typically Json or GenericRecord/SpecificRecord for Avro)

D - intermediate decoded input type

K - key for the output topic (if the result of async invocation is written to an output topic)

O - output value returned by async function

R - final result type that ends up in output topic

Parameters:

spec - a data structure with all the details required to set up the async invocation and process the results

topicBuildFn - a functional interface representing topic configuration steps

executor - the executor service that is used to invoke asynchronously and schedule timeouts

Returns:

the action processor build step

apply

public static <A,D,K,O,R> ActionProcessorBuildStep<A> apply(AsyncSpec<A,D,K,O,R> spec,
                                                            TopicConfigBuilder.BuildSteps topicBuildFn)

apply

public static <A,D,K,O,R> ActionProcessorBuildStep<A> apply(AsyncSpec<A,D,K,O,R> spec)

apply

public static <A,D,K,O,R> ActionProcessorBuildStep<A> apply(AsyncSpec<A,D,K,O,R> spec,
                                                            ScheduledExecutorService executor)