io.simplesource.saga.action.eventsourcing

Class EventSourcingContext<A,D,K,C>

java.lang.Object

io.simplesource.saga.action.eventsourcing.EventSourcingContext<A,D,K,C>

Type Parameters:

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

D - intermediate decoded input type (that can easily be converted to both K and C)

K - aggregate key

C - simple sourcing command type

public final class EventSourcingContext<A,D,K,C>
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
ActionSpec<A>	actionSpec
TopicNamer	actionTopicNamer
TopicNamer	commandTopicNamer
EventSourcingSpec<A,D,K,C>	eventSourcingSpec

Constructor Summary

Constructors

Constructor and Description
EventSourcingContext()

Method Summary

Modifier and Type	Method and Description
ActionSerdes<A>	aSerdes()
io.simplesource.kafka.api.CommandSerdes<K,C>	cSerdes()
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

eventSourcingSpec

public final EventSourcingSpec<A,D,K,C> eventSourcingSpec

actionTopicNamer

public final TopicNamer actionTopicNamer

commandTopicNamer

public final TopicNamer commandTopicNamer

Constructor Detail

EventSourcingContext

public EventSourcingContext()

Method Detail

getActionContext

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

cSerdes

public final io.simplesource.kafka.api.CommandSerdes<K,C> cSerdes()

aSerdes

public final ActionSerdes<A> aSerdes()