Package org.apache.camel.component.feed
Class FeedEntryPollingConsumer
- java.lang.Object
-
- org.apache.camel.support.service.BaseService
-
- org.apache.camel.support.service.ServiceSupport
-
- org.apache.camel.support.DefaultConsumer
-
- org.apache.camel.support.ScheduledPollConsumer
-
- org.apache.camel.component.feed.FeedPollingConsumer
-
- org.apache.camel.component.feed.FeedEntryPollingConsumer
-
- All Implemented Interfaces:
AutoCloseable
,Runnable
,org.apache.camel.Consumer
,org.apache.camel.EndpointAware
,org.apache.camel.PollingConsumerPollingStrategy
,org.apache.camel.RouteAware
,org.apache.camel.Service
,org.apache.camel.ShutdownableService
,org.apache.camel.spi.RouteIdAware
,org.apache.camel.StatefulService
,org.apache.camel.Suspendable
,org.apache.camel.SuspendableService
- Direct Known Subclasses:
AtomEntryPollingConsumer
public abstract class FeedEntryPollingConsumer extends FeedPollingConsumer
Consumer to poll feeds and return each entry from the feed step by step.
-
-
Field Summary
Fields Modifier and Type Field Description protected EntryFilter
entryFilter
protected int
entryIndex
protected Object
feed
protected List
list
protected boolean
throttleEntries
-
Fields inherited from class org.apache.camel.component.feed.FeedPollingConsumer
DEFAULT_CONSUMER_DELAY, endpoint
-
-
Constructor Summary
Constructors Constructor Description FeedEntryPollingConsumer(FeedEndpoint endpoint, org.apache.camel.Processor processor, boolean filter, Date lastUpdate, boolean throttleEntries)
-
Method Summary
All Methods Instance Methods Abstract Methods Concrete Methods Modifier and Type Method Description protected abstract EntryFilter
createEntryFilter(Date lastUpdate)
int
poll()
protected abstract void
populateList(Object feed)
protected abstract void
resetList()
-
Methods inherited from class org.apache.camel.component.feed.FeedPollingConsumer
createFeed
-
Methods inherited from class org.apache.camel.support.ScheduledPollConsumer
afterPoll, beforePoll, doInit, doShutdown, doStart, doStop, doSuspend, getBackoffCounter, getBackoffErrorThreshold, getBackoffIdleThreshold, getBackoffMultiplier, getDelay, getInitialDelay, getPollStrategy, getRepeatCount, getRunLoggingLevel, getScheduledExecutorService, getScheduler, getSchedulerProperties, getTimeUnit, isGreedy, isPollAllowed, isPolling, isSchedulerStarted, isSendEmptyMessageWhenIdle, isStartScheduler, isUseFixedDelay, onInit, processEmptyMessage, run, setBackoffErrorThreshold, setBackoffIdleThreshold, setBackoffMultiplier, setDelay, setGreedy, setInitialDelay, setPollStrategy, setRepeatCount, setRunLoggingLevel, setScheduledExecutorService, setScheduler, setSchedulerProperties, setSendEmptyMessageWhenIdle, setStartScheduler, setTimeUnit, setUseFixedDelay, startScheduler
-
Methods inherited from class org.apache.camel.support.DefaultConsumer
createUoW, doneUoW, getAsyncProcessor, getEndpoint, getExceptionHandler, getProcessor, getRoute, getRouteId, handleException, handleException, setExceptionHandler, setRoute, setRouteId, toString
-
Methods inherited from class org.apache.camel.support.service.BaseService
build, doBuild, doFail, doLifecycleChange, doResume, fail, getStatus, init, isBuild, isInit, isNew, isRunAllowed, isShutdown, isStarted, isStarting, isStartingOrStarted, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
-
-
-
-
Field Detail
-
entryIndex
protected int entryIndex
-
entryFilter
protected EntryFilter entryFilter
-
list
protected List list
-
throttleEntries
protected boolean throttleEntries
-
feed
protected Object feed
-
-
Constructor Detail
-
FeedEntryPollingConsumer
public FeedEntryPollingConsumer(FeedEndpoint endpoint, org.apache.camel.Processor processor, boolean filter, Date lastUpdate, boolean throttleEntries)
-
-
Method Detail
-
poll
public int poll() throws Exception
- Overrides:
poll
in classFeedPollingConsumer
- Throws:
Exception
-
createEntryFilter
protected abstract EntryFilter createEntryFilter(Date lastUpdate)
-
resetList
protected abstract void resetList()
-
-