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:
PulsarBatchMessagesToSpringMessageListenerAdapter
Batch message listener.
- Author:
- Soby Chacko
-
Method Summary
Modifier and TypeMethodDescriptionvoid
received
(org.apache.pulsar.client.api.Consumer<T> consumer, List<org.apache.pulsar.client.api.Message<T>> msg) default void
received
(org.apache.pulsar.client.api.Consumer<T> consumer, List<org.apache.pulsar.client.api.Message<T>> msg, Acknowledgement acknowledgement) default void
received
(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
reachedEndOfTopic
Methods 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:
received
in 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
-