Uses of Interface
org.apache.pulsar.client.api.Messages
-
Uses of Messages in org.apache.pulsar.client.api
Modifier and TypeMethodDescriptiondefault void
MessageAcknowledger.acknowledge
(Messages<?> messages) MessageAcknowledger.acknowledgeAsync
(Messages<?> messages) The asynchronous version ofMessageAcknowledger.acknowledge(Messages)
.MessageAcknowledger.acknowledgeAsync
(Messages<?> messages, Transaction txn) The asynchronous version ofMessageAcknowledger.acknowledge(Messages)
with transaction support.void
Consumer.negativeAcknowledge
(Messages<?> messages) Acknowledge the failure to processMessages
.void
Consumer.reconsumeLater
(Messages<?> messages, long delayTime, TimeUnit unit) reconsumeLater the consumption ofMessages
.Consumer.reconsumeLaterAsync
(Messages<?> messages, long delayTime, TimeUnit unit) Asynchronously reconsumeLater the consumption ofMessages
.