io.eventuate.tram.consumer.common

Interface MessageConsumerImplementation

All Known Implementing Classes:

EventuateTramActiveMQMessageConsumer, EventuateTramKafkaMessageConsumer, EventuateTramRabbitMQMessageConsumer, EventuateTramRedisMessageConsumer, InMemoryMessageConsumer

public interface MessageConsumerImplementation

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()