io.eventuate.tram.sagas.participant

Class SagaCommandDispatcher

java.lang.Object

io.eventuate.tram.commands.consumer.CommandDispatcher

io.eventuate.tram.sagas.participant.SagaCommandDispatcher

public class SagaCommandDispatcher
extends io.eventuate.tram.commands.consumer.CommandDispatcher

Constructor Summary

Constructors

Constructor and Description
SagaCommandDispatcher(java.lang.String commandDispatcherId, io.eventuate.tram.commands.consumer.CommandHandlers target, io.eventuate.tram.messaging.consumer.MessageConsumer messageConsumer, io.eventuate.tram.messaging.producer.MessageProducer messageProducer, SagaLockManager sagaLockManager)

Method Summary

Modifier and Type	Method and Description
protected java.util.List<io.eventuate.tram.messaging.common.Message>	invoke(io.eventuate.tram.commands.consumer.CommandHandler commandHandler, io.eventuate.tram.commands.consumer.CommandMessage cm, java.util.Map<java.lang.String,java.lang.String> pathVars)
void	messageHandler(io.eventuate.tram.messaging.common.Message message)

Methods inherited from class io.eventuate.tram.commands.consumer.CommandDispatcher

convertPayload, initialize

Methods inherited from class java.lang.Object

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

Constructor Detail

SagaCommandDispatcher

public SagaCommandDispatcher(java.lang.String commandDispatcherId,
                             io.eventuate.tram.commands.consumer.CommandHandlers target,
                             io.eventuate.tram.messaging.consumer.MessageConsumer messageConsumer,
                             io.eventuate.tram.messaging.producer.MessageProducer messageProducer,
                             SagaLockManager sagaLockManager)

Method Detail

messageHandler

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

Overrides:

messageHandler in class io.eventuate.tram.commands.consumer.CommandDispatcher

invoke

protected java.util.List<io.eventuate.tram.messaging.common.Message> invoke(io.eventuate.tram.commands.consumer.CommandHandler commandHandler,
                                                                            io.eventuate.tram.commands.consumer.CommandMessage cm,
                                                                            java.util.Map<java.lang.String,java.lang.String> pathVars)

Overrides:

invoke in class io.eventuate.tram.commands.consumer.CommandDispatcher