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, toString
doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
public NatsConsumer(NatsEndpoint endpoint, org.apache.camel.Processor processor)
public NatsEndpoint getEndpoint()
getEndpoint
in interface org.apache.camel.EndpointAware
getEndpoint
in class org.apache.camel.impl.DefaultConsumer
protected void doStart() throws Exception
doStart
in class org.apache.camel.impl.DefaultConsumer
Exception
protected void doStop() throws Exception
doStop
in class org.apache.camel.impl.DefaultConsumer
Exception
public boolean isSubscribed()
public void setSubscribed(boolean subscribed)
Apache Camel