Interface PulsarAcknowledgingMessageListener<T>
- Type Parameters:
T- payload type.
- All Superinterfaces:
org.apache.pulsar.client.api.MessageListener<T>,PulsarRecordMessageListener<T>,Serializable
- All Known Implementing Classes:
PulsarRecordMessagingMessageListenerAdapter,PulsarRecordMessagingMessageListenerAdapter
Message listener for manually acknowledging messages.
- Author:
- Soby Chacko
-
Method Summary
Methods inherited from interface org.apache.pulsar.client.api.MessageListener
reachedEndOfTopic
-
Method Details
-
received
default void received(org.apache.pulsar.client.api.Consumer<T> consumer, org.apache.pulsar.client.api.Message<T> msg) - Specified by:
receivedin interfaceorg.apache.pulsar.client.api.MessageListener<T>
-
received
void received(org.apache.pulsar.client.api.Consumer<T> consumer, org.apache.pulsar.client.api.Message<T> msg, Acknowledgement acknowledgement) - Specified by:
receivedin interfacePulsarRecordMessageListener<T>
-