public class DefaultTwitterConsumer extends org.apache.camel.impl.ScheduledPollConsumer implements TwitterEventListener
Modifier and Type | Field and Description |
---|---|
static long |
DEFAULT_CONSUMER_DELAY |
Constructor and Description |
---|
DefaultTwitterConsumer(AbstractTwitterEndpoint endpoint,
org.apache.camel.Processor processor,
AbstractTwitterConsumerHandler handler) |
Modifier and Type | Method and Description |
---|---|
protected void |
doStart() |
protected void |
doStop() |
AbstractTwitterEndpoint |
getEndpoint() |
void |
onEvent(org.apache.camel.Exchange exchange) |
protected 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, 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 static final long DEFAULT_CONSUMER_DELAY
public DefaultTwitterConsumer(AbstractTwitterEndpoint endpoint, org.apache.camel.Processor processor, AbstractTwitterConsumerHandler handler)
public AbstractTwitterEndpoint 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.ScheduledPollConsumer
Exception
protected void doStop() throws Exception
doStop
in class org.apache.camel.impl.ScheduledPollConsumer
Exception
protected int poll() throws Exception
poll
in class org.apache.camel.impl.ScheduledPollConsumer
Exception
public void onEvent(org.apache.camel.Exchange exchange)
onEvent
in interface TwitterEventListener
Apache Camel