io.eventuate.tram.consumer.common

Class MessageConsumerImpl

java.lang.Object

io.eventuate.tram.consumer.common.MessageConsumerImpl

All Implemented Interfaces:

MessageConsumer

public final class MessageConsumerImpl
extends java.lang.Object
implements MessageConsumer

Constructor Summary

Constructors

Constructor and Description
MessageConsumerImpl(ChannelMapping channelMapping, MessageConsumerImplementation target, DecoratedMessageHandlerFactory decoratedMessageHandlerFactory)

Method Summary

Modifier and Type	Method and Description
void	close()
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

MessageConsumerImpl

public MessageConsumerImpl(ChannelMapping channelMapping,
                           MessageConsumerImplementation target,
                           DecoratedMessageHandlerFactory decoratedMessageHandlerFactory)

Method Detail

subscribe

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

Specified by:

subscribe in interface MessageConsumer

getId

public java.lang.String getId()

Specified by:

getId in interface MessageConsumer

close

public void close()

Specified by:

close in interface MessageConsumer