Package org.apache.camel.component.atom
Class AtomEntryPollingConsumer
- 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
-
- org.apache.camel.component.atom.AtomEntryPollingConsumer
-
- 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
public class AtomEntryPollingConsumer extends FeedEntryPollingConsumer
Consumer to poll atom feeds and return each entry from the feed step by step.
-
-
Field Summary
-
Fields inherited from class org.apache.camel.component.feed.FeedEntryPollingConsumer
entryFilter, entryIndex, feed, list, throttleEntries
-
Fields inherited from class org.apache.camel.component.feed.FeedPollingConsumer
DEFAULT_CONSUMER_DELAY, endpoint
-
-
Constructor Summary
Constructors Constructor Description AtomEntryPollingConsumer(AtomEndpoint endpoint, org.apache.camel.Processor processor, boolean filter, Date lastUpdate, boolean throttleEntries)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected EntryFilter
createEntryFilter(Date lastUpdate)
protected Object
createFeed()
protected void
populateList(Object feed)
protected void
resetList()
protected void
sortEntries(org.apache.abdera.model.Feed feed)
-
Methods inherited from class org.apache.camel.component.feed.FeedEntryPollingConsumer
poll
-
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
-
-
-
-
Constructor Detail
-
AtomEntryPollingConsumer
public AtomEntryPollingConsumer(AtomEndpoint endpoint, org.apache.camel.Processor processor, boolean filter, Date lastUpdate, boolean throttleEntries)
-
-
Method Detail
-
sortEntries
protected void sortEntries(org.apache.abdera.model.Feed feed)
-
populateList
protected void populateList(Object feed) throws org.apache.abdera.parser.ParseException, IOException
- Specified by:
populateList
in classFeedEntryPollingConsumer
- Throws:
org.apache.abdera.parser.ParseException
IOException
-
createFeed
protected Object createFeed() throws IOException
- Specified by:
createFeed
in classFeedPollingConsumer
- Throws:
IOException
-
resetList
protected void resetList()
- Specified by:
resetList
in classFeedEntryPollingConsumer
-
createEntryFilter
protected EntryFilter createEntryFilter(Date lastUpdate)
- Specified by:
createEntryFilter
in classFeedEntryPollingConsumer
-
-