public class PulsarComponent
extends org.apache.camel.impl.DefaultComponent
Constructor and Description |
---|
PulsarComponent() |
PulsarComponent(org.apache.camel.CamelContext context) |
Modifier and Type | Method and Description |
---|---|
protected org.apache.camel.Endpoint |
createEndpoint(String uri,
String path,
Map<String,Object> parameters) |
AutoConfiguration |
getAutoConfiguration() |
org.apache.pulsar.client.api.PulsarClient |
getPulsarClient() |
PulsarMessageReceiptFactory |
getPulsarMessageReceiptFactory() |
boolean |
isAllowManualAcknowledgement() |
void |
setAllowManualAcknowledgement(boolean allowManualAcknowledgement)
Whether to allow manual message acknowledgements.
|
void |
setAutoConfiguration(AutoConfiguration autoConfiguration)
The pulsar autoconfiguration
|
void |
setPulsarClient(org.apache.pulsar.client.api.PulsarClient pulsarClient)
The pulsar client
|
void |
setPulsarMessageReceiptFactory(PulsarMessageReceiptFactory pulsarMessageReceiptFactory)
Provide a factory to create an alternate implementation of
PulsarMessageReceipt . |
afterConfiguration, createComponentConfiguration, createConfiguration, createEndpoint, doStart, doStop, getAndRemoveOrResolveReferenceParameter, getAndRemoveOrResolveReferenceParameter, getAndRemoveParameter, getAndRemoveParameter, getCamelContext, getExtension, getSupportedExtensions, ifStartsWithReturnRemainder, isResolvePropertyPlaceholders, preProcessUri, registerExtension, registerExtension, resolveAndRemoveReferenceListParameter, resolveAndRemoveReferenceListParameter, resolveAndRemoveReferenceParameter, resolveAndRemoveReferenceParameter, setCamelContext, setProperties, setProperties, setResolvePropertyPlaceholders, useIntrospectionOnEndpoint, useRawUri, validateParameters, validateURI
public PulsarComponent()
public PulsarComponent(org.apache.camel.CamelContext context)
protected org.apache.camel.Endpoint createEndpoint(String uri, String path, Map<String,Object> parameters) throws Exception
createEndpoint
in class org.apache.camel.impl.DefaultComponent
Exception
public AutoConfiguration getAutoConfiguration()
public void setAutoConfiguration(AutoConfiguration autoConfiguration)
public org.apache.pulsar.client.api.PulsarClient getPulsarClient()
public void setPulsarClient(org.apache.pulsar.client.api.PulsarClient pulsarClient)
public boolean isAllowManualAcknowledgement()
public void setAllowManualAcknowledgement(boolean allowManualAcknowledgement)
PulsarMessageReceipt
is stored as a header on the Exchange
.
Messages can then be acknowledged using PulsarMessageReceipt
at any time before the ackTimeout occurs.public PulsarMessageReceiptFactory getPulsarMessageReceiptFactory()
public void setPulsarMessageReceiptFactory(PulsarMessageReceiptFactory pulsarMessageReceiptFactory)
PulsarMessageReceipt
.Apache Camel