public class DefaultPulsarMessageReceiptFactory extends Object implements PulsarMessageReceiptFactory
Constructor and Description |
---|
DefaultPulsarMessageReceiptFactory() |
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 . |
public PulsarMessageReceipt newInstance(org.apache.camel.Exchange exchange, org.apache.pulsar.client.api.Message message, org.apache.pulsar.client.api.Consumer consumer)
PulsarMessageReceiptFactory
PulsarMessageReceipt
.newInstance
in interface PulsarMessageReceiptFactory
Apache Camel