Interface PulsarBatchMessageListener<T>
- Type Parameters:
T- payload type.
- All Superinterfaces:
org.apache.pulsar.client.api.MessageListener<T>,PulsarRecordMessageListener<T>,Serializable
- All Known Subinterfaces:
PulsarBatchAcknowledgingMessageListener<T>
- All Known Implementing Classes:
PulsarBatchMessagingMessageListenerAdapter
Batch message listener.
- Author:
- Soby Chacko
-
Method Summary
Modifier and TypeMethodDescriptionvoidreceived(org.apache.pulsar.client.api.Consumer<T> consumer, List<org.apache.pulsar.client.api.Message<T>> msg) default voidreceived(org.apache.pulsar.client.api.Consumer<T> consumer, List<org.apache.pulsar.client.api.Message<T>> msg, Acknowledgement acknowledgement) default voidreceived(org.apache.pulsar.client.api.Consumer<T> consumer, org.apache.pulsar.client.api.Message<T> msg) Methods inherited from interface org.apache.pulsar.client.api.MessageListener
reachedEndOfTopicMethods inherited from interface org.springframework.pulsar.listener.PulsarRecordMessageListener
received
-
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
default void received(org.apache.pulsar.client.api.Consumer<T> consumer, List<org.apache.pulsar.client.api.Message<T>> msg, Acknowledgement acknowledgement) -
received
-