Package org.springframework.pulsar.listener

Interface PulsarAcknowledgingMessageListener<T>

Type Parameters:
T - payload type.
All Superinterfaces:
org.apache.pulsar.client.api.MessageListener<T>, PulsarRecordMessageListener<T>, Serializable
All Known Implementing Classes:
PulsarRecordMessageToSpringMessageListenerAdapter
public interface PulsarAcknowledgingMessageListener<T> extends PulsarRecordMessageListener<T>
Message listener for manually acknowledging messages.
Author:
Soby Chacko

  • Method Summary

    Modifier and Type
    Method
    Description
    default void
    received(org.apache.pulsar.client.api.Consumer<T> consumer, org.apache.pulsar.client.api.Message<T> msg)
     
    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

  • 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

      void received(org.apache.pulsar.client.api.Consumer<T> consumer, org.apache.pulsar.client.api.Message<T> msg, Acknowledgement acknowledgement)
      Specified by:
      received in interface PulsarRecordMessageListener<T>