public class NatsConsumer
extends org.apache.camel.impl.DefaultConsumer
| Constructor and Description |
|---|
NatsConsumer(NatsEndpoint endpoint,
org.apache.camel.Processor processor) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
doStart() |
protected void |
doStop() |
NatsEndpoint |
getEndpoint() |
boolean |
isSubscribed() |
void |
setSubscribed(boolean subscribed) |
createUoW, doneUoW, getAsyncProcessor, getExceptionHandler, getProcessor, getRoute, handleException, handleException, setExceptionHandler, setRoute, toStringdoResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspendpublic NatsConsumer(NatsEndpoint endpoint, org.apache.camel.Processor processor)
public NatsEndpoint getEndpoint()
getEndpoint in interface org.apache.camel.EndpointAwaregetEndpoint in class org.apache.camel.impl.DefaultConsumerprotected void doStart()
throws Exception
doStart in class org.apache.camel.impl.DefaultConsumerExceptionprotected void doStop()
throws Exception
doStop in class org.apache.camel.impl.DefaultConsumerExceptionpublic boolean isSubscribed()
public void setSubscribed(boolean subscribed)
Apache Camel