Package org.springframework.pulsar.listener

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
public interface PulsarBatchMessageListener<T> extends PulsarRecordMessageListener<T>
Batch message listener.
Author:
Soby Chacko

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    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 interface org.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

      void received(org.apache.pulsar.client.api.Consumer<T> consumer, List<org.apache.pulsar.client.api.Message<T>> msg)