io.eventuate.tram.testing

Class MessageTracker

java.lang.Object

io.eventuate.tram.testing.MessageTracker

public class MessageTracker
extends java.lang.Object

Subscribes to a specified set of channels Provides methods for asserting that a command or event was received

Constructor Summary

Constructors

Constructor and Description
MessageTracker(java.util.Set<java.lang.String> channels, MessageConsumer messageConsumer)

Method Summary

Modifier and Type	Method and Description
<C extends io.eventuate.tram.commands.common.Command> void	assertCommandMessageSent(java.lang.String channel, java.lang.Class<C> expectedCommandClass)
<C extends DomainEvent> void	assertDomainEventPublished(java.lang.String channel, java.lang.Class<C> expectedDomainEventClass)
void	assertDomainEventPublished(java.lang.String channel, java.lang.String expectedDomainEventClassName)
void	reset()

Methods inherited from class java.lang.Object

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

Constructor Detail

MessageTracker

public MessageTracker(java.util.Set<java.lang.String> channels,
                      MessageConsumer messageConsumer)

Method Detail

reset

public void reset()

assertCommandMessageSent

public <C extends io.eventuate.tram.commands.common.Command> void assertCommandMessageSent(java.lang.String channel,
                                                                                           java.lang.Class<C> expectedCommandClass)

assertDomainEventPublished

public void assertDomainEventPublished(java.lang.String channel,
                                       java.lang.String expectedDomainEventClassName)

assertDomainEventPublished

public <C extends DomainEvent> void assertDomainEventPublished(java.lang.String channel,
                                                               java.lang.Class<C> expectedDomainEventClass)