io.eventuate.tram.sagas.testing.commandhandling

Class UnhandledMessageTrackingCommandDispatcher

java.lang.Object

io.eventuate.tram.commands.consumer.CommandDispatcher

io.eventuate.tram.sagas.testing.commandhandling.UnhandledMessageTrackingCommandDispatcher

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

Constructor Summary

Constructors

Constructor and Description
UnhandledMessageTrackingCommandDispatcher(java.lang.String commandDispatcherId, io.eventuate.tram.commands.consumer.CommandHandlers commandHandlers, io.eventuate.tram.messaging.consumer.MessageConsumer messageConsumer, io.eventuate.tram.messaging.producer.MessageProducer messageProducer)

Method Summary

Modifier and Type	Method and Description
void	messageHandler(io.eventuate.tram.messaging.common.Message message)
<C> void	noteNewCommandHandler(SagaParticipantStubCommandHandler<C> commandHandler)
void	reset()

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

convertPayload, initialize, invoke

Methods inherited from class java.lang.Object

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

Constructor Detail

UnhandledMessageTrackingCommandDispatcher

public UnhandledMessageTrackingCommandDispatcher(java.lang.String commandDispatcherId,
                                                 io.eventuate.tram.commands.consumer.CommandHandlers commandHandlers,
                                                 io.eventuate.tram.messaging.consumer.MessageConsumer messageConsumer,
                                                 io.eventuate.tram.messaging.producer.MessageProducer messageProducer)

Method Detail

messageHandler

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

Overrides:

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

reset

public void reset()

noteNewCommandHandler

public <C> void noteNewCommandHandler(SagaParticipantStubCommandHandler<C> commandHandler)