public abstract class FeedEntryPollingConsumer extends FeedPollingConsumer
Modifier and Type | Field and Description |
---|---|
protected EntryFilter |
entryFilter |
protected int |
entryIndex |
protected Object |
feed |
protected List |
list |
protected boolean |
throttleEntries |
DEFAULT_CONSUMER_DELAY, endpoint
Constructor and Description |
---|
FeedEntryPollingConsumer(FeedEndpoint endpoint,
org.apache.camel.Processor processor,
boolean filter,
Date lastUpdate,
boolean throttleEntries) |
Modifier and Type | Method and Description |
---|---|
protected abstract EntryFilter |
createEntryFilter(Date lastUpdate) |
int |
poll() |
protected abstract void |
populateList(Object feed) |
protected abstract void |
resetList() |
createFeed
afterPoll, beforePoll, doShutdown, doStart, doStop, 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 int entryIndex
protected EntryFilter entryFilter
protected List list
protected boolean throttleEntries
protected Object feed
public FeedEntryPollingConsumer(FeedEndpoint endpoint, org.apache.camel.Processor processor, boolean filter, Date lastUpdate, boolean throttleEntries)
public int poll() throws Exception
poll
in class FeedPollingConsumer
Exception
protected abstract EntryFilter createEntryFilter(Date lastUpdate)
protected abstract void resetList()
Apache Camel