public interface MessageListener extends Serializable
|Modifier and Type||Method and Description|
Get the notification when a topic is terminated
This method is called whenever a new message is received.
consumer- the consumer that received the message
msg- the message object
default void reachedEndOfTopic(Consumer consumer)
consumer- the Consumer object associated with the terminated topic