io.eventuate.tram.testutil

Class TestMessageConsumer

java.lang.Object

io.eventuate.tram.testutil.TestMessageConsumer

All Implemented Interfaces:

MessageHandler, java.util.function.Consumer<Message>

public class TestMessageConsumer
extends java.lang.Object
implements MessageHandler

Constructor Summary

Constructors

Constructor and Description
TestMessageConsumer(java.lang.String replyChannel)

Method Summary

Modifier and Type	Method and Description
void	accept(Message message)
void	assertHasReplyTo(java.lang.String messageId)
boolean	containsReplyTo(java.lang.String messageId)
java.lang.String	getReplyChannel()

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.function.Consumer

andThen

Constructor Detail

TestMessageConsumer

public TestMessageConsumer(java.lang.String replyChannel)

Method Detail

getReplyChannel

public java.lang.String getReplyChannel()

accept

public void accept(Message message)

Specified by:

accept in interface java.util.function.Consumer<Message>

containsReplyTo

public boolean containsReplyTo(java.lang.String messageId)

assertHasReplyTo

public void assertHasReplyTo(java.lang.String messageId)