Interface PulsarRecordMessageListener<T>
- Type Parameters:
T- message payload type
- All Superinterfaces:
org.apache.pulsar.client.api.MessageListener<T>,Serializable
- All Known Subinterfaces:
PulsarAcknowledgingMessageListener<T>,PulsarBatchAcknowledgingMessageListener<T>,PulsarBatchMessageListener<T>
- All Known Implementing Classes:
PulsarBatchMessagingMessageListenerAdapter,PulsarRecordMessagingMessageListenerAdapter,PulsarRecordMessagingMessageListenerAdapter
public interface PulsarRecordMessageListener<T>
extends org.apache.pulsar.client.api.MessageListener<T>
Base record MessageListener that simply extends from
MessageListener. This
extension is needed as a base class to deal with acknowledgments in the framework.- Author:
- Soby Chacko
-
Method Summary
Modifier and TypeMethodDescriptiondefault voidreceived(org.apache.pulsar.client.api.Consumer<T> consumer, org.apache.pulsar.client.api.Message<T> msg, Acknowledgement acknowledgement) Methods inherited from interface org.apache.pulsar.client.api.MessageListener
reachedEndOfTopic, received
-
Method Details
-
received
default void received(org.apache.pulsar.client.api.Consumer<T> consumer, org.apache.pulsar.client.api.Message<T> msg, Acknowledgement acknowledgement)
-