io.eventuate.tram.sagas.orchestration

Class SagaManagerImpl<Data>

java.lang.Object

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

All Implemented Interfaces:

SagaManager<Data>

public class SagaManagerImpl<Data>
extends java.lang.Object
implements SagaManager<Data>

Constructor Summary

Constructors

Constructor and Description
SagaManagerImpl(Saga<Data> saga, SagaInstanceRepository sagaInstanceRepository, io.eventuate.tram.commands.producer.CommandProducer commandProducer, io.eventuate.tram.messaging.consumer.MessageConsumer messageConsumer, SagaLockManager sagaLockManager, SagaCommandProducer sagaCommandProducer)

Method Summary

Modifier and Type	Method and Description
SagaInstance	create(Data sagaData)
SagaInstance	create(Data data, java.lang.Class targetClass, java.lang.Object targetId)
SagaInstance	create(Data sagaData, java.util.Optional<java.lang.String> resource)
void	handleMessage(io.eventuate.tram.messaging.common.Message message)
void	setCommandProducer(io.eventuate.tram.commands.producer.CommandProducer commandProducer)
void	setMessageConsumer(io.eventuate.tram.messaging.consumer.MessageConsumer messageConsumer)
void	setSagaCommandProducer(SagaCommandProducer sagaCommandProducer)
void	setSagaInstanceRepository(SagaInstanceRepository sagaInstanceRepository)
void	setSagaLockManager(SagaLockManager sagaLockManager)
void	subscribeToReplyChannel()

Methods inherited from class java.lang.Object

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

Constructor Detail

SagaManagerImpl

public SagaManagerImpl(Saga<Data> saga,
                       SagaInstanceRepository sagaInstanceRepository,
                       io.eventuate.tram.commands.producer.CommandProducer commandProducer,
                       io.eventuate.tram.messaging.consumer.MessageConsumer messageConsumer,
                       SagaLockManager sagaLockManager,
                       SagaCommandProducer sagaCommandProducer)

Method Detail

setSagaCommandProducer

public void setSagaCommandProducer(SagaCommandProducer sagaCommandProducer)

setSagaInstanceRepository

public void setSagaInstanceRepository(SagaInstanceRepository sagaInstanceRepository)

setCommandProducer

public void setCommandProducer(io.eventuate.tram.commands.producer.CommandProducer commandProducer)

setMessageConsumer

public void setMessageConsumer(io.eventuate.tram.messaging.consumer.MessageConsumer messageConsumer)

setSagaLockManager

public void setSagaLockManager(SagaLockManager sagaLockManager)

create

public SagaInstance create(Data sagaData)

Specified by:

create in interface SagaManager<Data>

create

public SagaInstance create(Data data,
                           java.lang.Class targetClass,
                           java.lang.Object targetId)

Specified by:

create in interface SagaManager<Data>

create

public SagaInstance create(Data sagaData,
                           java.util.Optional<java.lang.String> resource)

Specified by:

create in interface SagaManager<Data>

subscribeToReplyChannel

@PostConstruct
public void subscribeToReplyChannel()

Specified by:

subscribeToReplyChannel in interface SagaManager<Data>

handleMessage

public void handleMessage(io.eventuate.tram.messaging.common.Message message)