Package org.springframework.pulsar.listener

Interface PulsarRecordMessageListener<T>

Type Parameters:
T - message payload type
All Superinterfaces:
org.apache.pulsar.client.api.MessageListener<T>, Serializable
All Known Subinterfaces:
PulsarAcknowledgingMessageListener<T>, PulsarBatchAcknowledgingMessageListener<T>, PulsarBatchMessageListener<T>
All Known Implementing Classes:
PulsarBatchMessagesToSpringMessageListenerAdapter, PulsarRecordMessageToSpringMessageListenerAdapter
public interface PulsarRecordMessageListener<T> extends org.apache.pulsar.client.api.MessageListener<T>
Base record MessageListener that simply extends from MessageListener. This extension is needed as a base class to deal with acknowledgments in the framework.
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, Acknowledgement acknowledgement)
     

    Methods inherited from interface org.apache.pulsar.client.api.MessageListener

    reachedEndOfTopic, received

  • Method Details

    • received

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