io.eventuate.tram.sagas.orchestration

Class SagaEventHandler<Data>

java.lang.Object

io.eventuate.tram.sagas.orchestration.SagaEventHandler<Data>

public class SagaEventHandler<Data>
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
SagaEventHandler(java.lang.Class<io.eventuate.tram.events.common.DomainEvent> eventClass, java.util.function.Function<Data,java.lang.Long> aggregateIdProvider, SagaStateMachineAction<Data,io.eventuate.tram.events.subscriber.DomainEventEnvelope<io.eventuate.tram.events.common.DomainEvent>> action)

Method Summary

Modifier and Type	Method and Description
EventClassAndAggregateId	eventClassAndAggregateId(Data data)
SagaStateMachineAction<Data,io.eventuate.tram.events.subscriber.DomainEventEnvelope<io.eventuate.tram.events.common.DomainEvent>>	getAction()
java.lang.Class<io.eventuate.tram.events.common.DomainEvent>	getEventClass()
static <Data> SagaEventHandler	make(java.lang.Class<io.eventuate.tram.events.common.DomainEvent> eventClass, java.util.function.Function<Data,java.lang.Long> aggregateIdProvider, SagaStateMachineAction<Data,io.eventuate.tram.events.subscriber.DomainEventEnvelope<io.eventuate.tram.events.common.DomainEvent>> eventHandler)

Methods inherited from class java.lang.Object

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

Constructor Detail

SagaEventHandler

public SagaEventHandler(java.lang.Class<io.eventuate.tram.events.common.DomainEvent> eventClass,
                        java.util.function.Function<Data,java.lang.Long> aggregateIdProvider,
                        SagaStateMachineAction<Data,io.eventuate.tram.events.subscriber.DomainEventEnvelope<io.eventuate.tram.events.common.DomainEvent>> action)

Method Detail

make

public static <Data> SagaEventHandler make(java.lang.Class<io.eventuate.tram.events.common.DomainEvent> eventClass,
                                           java.util.function.Function<Data,java.lang.Long> aggregateIdProvider,
                                           SagaStateMachineAction<Data,io.eventuate.tram.events.subscriber.DomainEventEnvelope<io.eventuate.tram.events.common.DomainEvent>> eventHandler)

eventClassAndAggregateId

public EventClassAndAggregateId eventClassAndAggregateId(Data data)

getEventClass

public java.lang.Class<io.eventuate.tram.events.common.DomainEvent> getEventClass()

getAction

public SagaStateMachineAction<Data,io.eventuate.tram.events.subscriber.DomainEventEnvelope<io.eventuate.tram.events.common.DomainEvent>> getAction()