io.eventuate.tram.inmemory

Class InMemoryMessageConsumer

java.lang.Object

io.eventuate.tram.inmemory.InMemoryMessageConsumer

All Implemented Interfaces:

MessageConsumerImplementation

public class InMemoryMessageConsumer
extends java.lang.Object
implements MessageConsumerImplementation

Constructor Summary

Constructors

Constructor and Description
InMemoryMessageConsumer()

Method Summary

Modifier and Type	Method and Description
void	close()
void	dispatchMessage(Message message)
java.lang.String	getId()
MessageSubscription	subscribe(java.lang.String subscriberId, java.util.Set<java.lang.String> channels, MessageHandler handler)

Methods inherited from class java.lang.Object

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

Constructor Detail

InMemoryMessageConsumer

public InMemoryMessageConsumer()

Method Detail

dispatchMessage

public void dispatchMessage(Message message)

subscribe

public MessageSubscription subscribe(java.lang.String subscriberId,
                                     java.util.Set<java.lang.String> channels,
                                     MessageHandler handler)

Specified by:

subscribe in interface MessageConsumerImplementation

getId

public java.lang.String getId()

Specified by:

getId in interface MessageConsumerImplementation

close

public void close()

Specified by:

close in interface MessageConsumerImplementation