Uses of Interface
org.springframework.pulsar.listener.Acknowledgement
Packages that use 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
Methods in org.springframework.pulsar.listener with parameters of type AcknowledgementModifier and TypeMethodDescriptionvoidPulsarAcknowledgingMessageListener.received(org.apache.pulsar.client.api.Consumer<T> consumer, org.apache.pulsar.client.api.Message<T> msg, Acknowledgement acknowledgement) voidPulsarBatchAcknowledgingMessageListener.received(org.apache.pulsar.client.api.Consumer<T> consumer, List<org.apache.pulsar.client.api.Message<T>> msg, Acknowledgement acknowledgement) default voidPulsarBatchMessageListener.received(org.apache.pulsar.client.api.Consumer<T> consumer, List<org.apache.pulsar.client.api.Message<T>> msg, Acknowledgement acknowledgement) default voidPulsarRecordMessageListener.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
Methods in org.springframework.pulsar.listener.adapter with parameters of type AcknowledgementModifier and TypeMethodDescriptionprotected voidPulsarBatchMessagesToSpringMessageListenerAdapter.invoke(Object records, org.apache.pulsar.client.api.Consumer<V> consumer, Message<?> message, Acknowledgement acknowledgement) voidPulsarBatchMessagesToSpringMessageListenerAdapter.received(org.apache.pulsar.client.api.Consumer<V> consumer, List<org.apache.pulsar.client.api.Message<V>> msg, Acknowledgement acknowledgement) voidPulsarRecordMessageToSpringMessageListenerAdapter.received(org.apache.pulsar.client.api.Consumer<V> consumer, org.apache.pulsar.client.api.Message<V> record, Acknowledgement acknowledgement)