public interface PulsarMessageReceipt
Available on the Exchange
if PulsarConfiguration.isAllowManualAcknowledgement()
is true.
An alternative to the default may be provided by implementing PulsarMessageReceiptFactory
.
Modifier and Type | Method and Description |
---|---|
void |
acknowledge()
Acknowledge receipt of this message synchronously.
|
CompletableFuture<Void> |
acknowledgeAsync()
Acknowledge receipt of this message asynchronously.
|
void |
acknowledgeCumulative()
Acknowledge receipt of all of the messages in the stream up to and including this message synchronously.
|
CompletableFuture<Void> |
acknowledgeCumulativeAsync()
Acknowledge receipt of all of the messages in the stream up to and including this message asynchronously.
|
void |
negativeAcknowledge()
Acknowledge the failure to process this message.
|
void acknowledge() throws org.apache.pulsar.client.api.PulsarClientException
org.apache.pulsar.client.api.PulsarClientException
Consumer.acknowledge(MessageId)
void acknowledgeCumulative() throws org.apache.pulsar.client.api.PulsarClientException
org.apache.pulsar.client.api.PulsarClientException
Consumer.acknowledgeCumulative(MessageId)
CompletableFuture<Void> acknowledgeAsync()
Consumer.acknowledgeAsync(MessageId)
CompletableFuture<Void> acknowledgeCumulativeAsync()
Consumer.acknowledgeCumulativeAsync(MessageId)
void negativeAcknowledge()
Note: Available in Puslar 2.4.0. Implementations with earlier versions should return an {@link java.lang.UnsupportedOperationException}.
Apache Camel