public class CouchbaseConsumer
extends org.apache.camel.impl.DefaultScheduledPollConsumer
Constructor and Description |
---|
CouchbaseConsumer(CouchbaseEndpoint endpoint,
com.couchbase.client.CouchbaseClient client,
org.apache.camel.Processor processor) |
Modifier and Type | Method and Description |
---|---|
protected void |
doStart() |
protected void |
doStop() |
protected int |
poll() |
getTimeout, setTimeout
afterPoll, beforePoll, doShutdown, doSuspend, getBackoffCounter, getBackoffErrorThreshold, getBackoffIdleThreshold, getBackoffMultiplier, getDelay, getInitialDelay, getPollStrategy, getRunLoggingLevel, getScheduledExecutorService, getScheduler, getSchedulerProperties, getTimeUnit, isGreedy, isPollAllowed, isPolling, isSchedulerStarted, isSendEmptyMessageWhenIdle, isStartScheduler, isUseFixedDelay, onInit, processEmptyMessage, run, setBackoffErrorThreshold, setBackoffIdleThreshold, setBackoffMultiplier, setDelay, setGreedy, setInitialDelay, setPollStrategy, setRunLoggingLevel, setScheduledExecutorService, setScheduler, setSchedulerProperties, setSendEmptyMessageWhenIdle, setStartScheduler, setTimeUnit, setUseFixedDelay, startScheduler
createUoW, doneUoW, getAsyncProcessor, getEndpoint, getExceptionHandler, getProcessor, getRoute, handleException, handleException, setExceptionHandler, setRoute, toString
doResume, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
public CouchbaseConsumer(CouchbaseEndpoint endpoint, com.couchbase.client.CouchbaseClient client, org.apache.camel.Processor processor)
protected void doStart() throws Exception
doStart
in class org.apache.camel.impl.DefaultScheduledPollConsumer
Exception
protected void doStop() throws Exception
doStop
in class org.apache.camel.impl.DefaultScheduledPollConsumer
Exception
Apache Camel