Uses of Interface
org.springframework.pulsar.listener.Acknowledgement
Package
Description
Package containing listener components for receiving Pulsar messages.
Package containing components for adapting Pulsar messages to message listeners.
-
Uses of Acknowledgement in org.springframework.pulsar.listener
Modifier and TypeMethodDescriptionvoid
PulsarAcknowledgingMessageListener.received
(org.apache.pulsar.client.api.Consumer<T> consumer, org.apache.pulsar.client.api.Message<T> msg, Acknowledgement acknowledgement) void
PulsarBatchAcknowledgingMessageListener.received
(org.apache.pulsar.client.api.Consumer<T> consumer, List<org.apache.pulsar.client.api.Message<T>> msg, Acknowledgement acknowledgement) default void
PulsarBatchMessageListener.received
(org.apache.pulsar.client.api.Consumer<T> consumer, List<org.apache.pulsar.client.api.Message<T>> msg, Acknowledgement acknowledgement) default void
PulsarRecordMessageListener.received
(org.apache.pulsar.client.api.Consumer<T> consumer, org.apache.pulsar.client.api.Message<T> msg, Acknowledgement acknowledgement) -
Uses of Acknowledgement in org.springframework.pulsar.listener.adapter
Modifier and TypeMethodDescriptionprotected void
PulsarBatchMessagesToSpringMessageListenerAdapter.invoke
(Object records, org.apache.pulsar.client.api.Consumer<V> consumer, Message<?> message, Acknowledgement acknowledgement) void
PulsarBatchMessagesToSpringMessageListenerAdapter.received
(org.apache.pulsar.client.api.Consumer<V> consumer, List<org.apache.pulsar.client.api.Message<V>> msg, Acknowledgement acknowledgement) void
PulsarRecordMessageToSpringMessageListenerAdapter.received
(org.apache.pulsar.client.api.Consumer<V> consumer, org.apache.pulsar.client.api.Message<V> record, Acknowledgement acknowledgement)