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