io.eventuate.tram.messaging.consumer

Interface MessageConsumer

All Known Implementing Classes:

MessageConsumerImpl

public interface MessageConsumer

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)

Method Detail

subscribe

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

getId

java.lang.String getId()

close

void close()