public class AtmosScheduledPollGetConsumer extends AtmosScheduledPollConsumer
configuration, endpoint, LOG
Constructor and Description |
---|
AtmosScheduledPollGetConsumer(AtmosEndpoint endpoint,
org.apache.camel.Processor processor,
AtmosConfiguration configuration) |
Modifier and Type | Method and Description |
---|---|
protected int |
poll()
Poll from an atmos remote path and put the result in the message exchange
|
doStart, doStop
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 AtmosScheduledPollGetConsumer(AtmosEndpoint endpoint, org.apache.camel.Processor processor, AtmosConfiguration configuration)
protected int poll() throws Exception
poll
in class AtmosScheduledPollConsumer
Exception
Apache Camel