public abstract class AtmosScheduledPollConsumer
extends org.apache.camel.impl.ScheduledPollConsumer
Modifier and Type | Field and Description |
---|---|
protected AtmosConfiguration |
configuration |
protected AtmosEndpoint |
endpoint |
protected static org.slf4j.Logger |
LOG |
Constructor and Description |
---|
AtmosScheduledPollConsumer(AtmosEndpoint endpoint,
org.apache.camel.Processor processor,
AtmosConfiguration configuration) |
Modifier and Type | Method and Description |
---|---|
protected void |
doStart()
Lifecycle method invoked when the consumer has created.
|
protected void |
doStop()
Lifecycle method invoked when the consumer has destroyed.
|
protected abstract int |
poll() |
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
protected static final transient org.slf4j.Logger LOG
protected AtmosEndpoint endpoint
protected AtmosConfiguration configuration
public AtmosScheduledPollConsumer(AtmosEndpoint endpoint, org.apache.camel.Processor processor, AtmosConfiguration configuration)
protected abstract int poll() throws Exception
poll
in class org.apache.camel.impl.ScheduledPollConsumer
Exception
protected void doStart() throws Exception
doStart
in class org.apache.camel.impl.ScheduledPollConsumer
Exception
Apache Camel