Package org.springframework.pulsar.listener

Interface PulsarBatchAcknowledgingMessageListener<T>

Type Parameters:
T - payload type.
All Superinterfaces:
org.apache.pulsar.client.api.MessageListener<T>, PulsarBatchMessageListener<T>, PulsarRecordMessageListener<T>, Serializable
All Known Implementing Classes:
PulsarBatchMessagesToSpringMessageListenerAdapter
public interface PulsarBatchAcknowledgingMessageListener<T> extends PulsarBatchMessageListener<T>
Batch message listener that allows manual acknowledgment.
Author:
Soby Chacko

  • Method Summary

    Modifier and Type
    Method
    Description
    default void
    received(org.apache.pulsar.client.api.Consumer<T> consumer, List<org.apache.pulsar.client.api.Message<T>> msg)
     
    void
    received(org.apache.pulsar.client.api.Consumer<T> consumer, List<org.apache.pulsar.client.api.Message<T>> msg, Acknowledgement acknowledgement)
     

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

    reachedEndOfTopic

    Methods inherited from interface org.springframework.pulsar.listener.PulsarBatchMessageListener

    received

    Methods inherited from interface org.springframework.pulsar.listener.PulsarRecordMessageListener

    received