io.simplesource.saga.action.http

Class HttpBuilder

java.lang.Object

io.simplesource.saga.action.http.HttpBuilder

public final class HttpBuilder
extends Object

The Http builder is a thin wrapper around the AsyncBuilder that makes it easier to wrap Http web service calls as async actions. The client still has to provide an HttpSpec.asyncHttpFunction implementation using the Http client of their choice.

Constructor Summary

Constructors

Constructor and Description
HttpBuilder()

Method Summary

Modifier and Type	Method and Description
static <A,D,K,O,R> ActionProcessorBuildStep<A>	apply(HttpSpec<A,D,K,O,R> spec)
static <A,D,K,O,R> ActionProcessorBuildStep<A>	apply(HttpSpec<A,D,K,O,R> spec, ScheduledExecutorService executor)
static <A,D,K,O,R> ActionProcessorBuildStep<A>	apply(HttpSpec<A,D,K,O,R> spec, TopicConfigBuilder.BuildSteps topicBuildFn)
static <A,K,B,O,R> ActionProcessorBuildStep<A>	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.

Methods inherited from class java.lang.Object

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

Constructor Detail

HttpBuilder

public HttpBuilder()

Method Detail

apply

public static <A,K,B,O,R> ActionProcessorBuildStep<A> 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.

Type Parameters:

A - common representation type for all action commands (typically Json / GenericRecord for Avro)

K - key for the output topic for the result of Http topics

B - body for Http request

O - value returned by the Http request - also normally quite generic

R - final result type that ends up in value topic

Parameters:

httpSpec - the http spec

topicBuildFn - the topic build fn

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(HttpSpec<A,D,K,O,R> spec,
                                                            TopicConfigBuilder.BuildSteps topicBuildFn)

apply

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

apply

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