public class PulsarConsumer
extends org.apache.camel.impl.DefaultConsumer
Constructor and Description |
---|
PulsarConsumer(PulsarEndpoint pulsarEndpoint,
org.apache.camel.Processor processor) |
Modifier and Type | Method and Description |
---|---|
protected void |
doResume() |
protected void |
doStart() |
protected void |
doStop() |
protected void |
doSuspend() |
createUoW, doneUoW, getAsyncProcessor, getEndpoint, getExceptionHandler, getProcessor, getRoute, handleException, handleException, setExceptionHandler, setRoute, toString
doShutdown, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
public PulsarConsumer(PulsarEndpoint pulsarEndpoint, org.apache.camel.Processor processor)
protected void doStart() throws Exception
doStart
in class org.apache.camel.impl.DefaultConsumer
Exception
protected void doStop() throws org.apache.pulsar.client.api.PulsarClientException
doStop
in class org.apache.camel.impl.DefaultConsumer
org.apache.pulsar.client.api.PulsarClientException
protected void doSuspend() throws org.apache.pulsar.client.api.PulsarClientException
doSuspend
in class org.apache.camel.support.ServiceSupport
org.apache.pulsar.client.api.PulsarClientException
Apache Camel