io.simplesource.saga.action.async

Class AsyncContext<A,D,K,O,R>

java.lang.Object

io.simplesource.saga.action.async.AsyncContext<A,D,K,O,R>

Type Parameters:

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

D - intermediate decoded input type (this can be specific to this action processor)

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 (if output is generated)

public final class AsyncContext<A,D,K,O,R>
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
ActionSpec<A>	actionSpec
TopicNamer	actionTopicNamer
AsyncSpec<A,D,K,O,R>	asyncSpec
ScheduledExecutorService	executor

Constructor Summary

Constructors

Constructor and Description
AsyncContext()

Method Summary

Modifier and Type	Method and Description
io.simplesource.saga.action.internal.ActionContext<A>	getActionContext()

Methods inherited from class java.lang.Object

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

Field Detail

actionSpec

public final ActionSpec<A> actionSpec

actionTopicNamer

public final TopicNamer actionTopicNamer

asyncSpec

public final AsyncSpec<A,D,K,O,R> asyncSpec

executor

public final ScheduledExecutorService executor

Constructor Detail

AsyncContext

public AsyncContext()

Method Detail

getActionContext

public io.simplesource.saga.action.internal.ActionContext<A> getActionContext()