io.simplesource.saga.action.http

Class HttpSpec<A,K,B,O,R>

java.lang.Object

io.simplesource.saga.action.http.HttpSpec<A,K,B,O,R>

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

public final class HttpSpec<A,K,B,O,R>
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	HttpSpec.UndoFunction<A,K,B,O> The UndoFunction functional interface.

Field Summary

Fields

Modifier and Type	Field and Description
String	actionType
java.util.function.BiConsumer<HttpRequest<K,B>,Callback<O>>	asyncHttpFunction
HttpRequest.HttpRequestDecoder<A,K,B>	decoder
String	groupId
Optional<HttpOutput<K,O,R>>	outputSpec
Optional<java.time.Duration>	timeout
HttpSpec.UndoFunction<A,K,B,O>	undoFunction

Constructor Summary

Constructors

Constructor and Description
HttpSpec()

Method Summary

Methods inherited from class java.lang.Object

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

Field Detail

actionType

public final String actionType

decoder

public final HttpRequest.HttpRequestDecoder<A,K,B> decoder

asyncHttpFunction

public final java.util.function.BiConsumer<HttpRequest<K,B>,Callback<O>> asyncHttpFunction

groupId

public final String groupId

outputSpec

public final Optional<HttpOutput<K,O,R>> outputSpec

undoFunction

public final HttpSpec.UndoFunction<A,K,B,O> undoFunction

timeout

public final Optional<java.time.Duration> timeout

Constructor Detail

HttpSpec

public HttpSpec()