public interface PulsarMessageReceiptFactory
PulsarMessageReceipt
to store on the Exchange
.
Implement this interface if an alternate implementation of PulsarMessageReceipt
is required
as newer Pulsar clients may have acknowledgement functionality not yet supported by DefaultPulsarMessageReceipt
.
Modifier and Type | Method and Description |
---|---|
PulsarMessageReceipt |
newInstance(org.apache.camel.Exchange exchange,
org.apache.pulsar.client.api.Message message,
org.apache.pulsar.client.api.Consumer consumer)
Creates a new instance of
PulsarMessageReceipt . |
PulsarMessageReceipt newInstance(org.apache.camel.Exchange exchange, org.apache.pulsar.client.api.Message message, org.apache.pulsar.client.api.Consumer consumer)
PulsarMessageReceipt
.Apache Camel