org.apache.camel.component.rss
Class RssEntryPollingConsumer

java.lang.Object
  extended by org.apache.camel.support.ServiceSupport
      extended by org.apache.camel.impl.DefaultConsumer
          extended by org.apache.camel.impl.ScheduledPollConsumer
              extended by org.apache.camel.component.feed.FeedPollingConsumer
                  extended by org.apache.camel.component.feed.FeedEntryPollingConsumer
                      extended by org.apache.camel.component.rss.RssEntryPollingConsumer
All Implemented Interfaces:
Runnable, org.apache.camel.Consumer, org.apache.camel.PollingConsumerPollingStrategy, org.apache.camel.RouteAware, org.apache.camel.Service, org.apache.camel.ShutdownableService, org.apache.camel.StatefulService, org.apache.camel.SuspendableService

public class RssEntryPollingConsumer
extends org.apache.camel.component.feed.FeedEntryPollingConsumer

Consumer to poll RSS 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
 
Fields inherited from class org.apache.camel.impl.DefaultConsumer
log
 
Fields inherited from class org.apache.camel.support.ServiceSupport
shutdown, shuttingdown, started, starting, stopped, stopping, suspended, suspending
 
Constructor Summary
RssEntryPollingConsumer(RssEndpoint endpoint, org.apache.camel.Processor processor, boolean filter, Date lastUpdate, boolean throttleEntries)
           
 
Method Summary
protected  org.apache.camel.component.feed.EntryFilter createEntryFilter(Date lastUpdate)
           
protected  Object createFeed()
           
protected  void populateList(Object feed)
           
protected  void resetList()
           
protected  void sortEntries()
           
 
Methods inherited from class org.apache.camel.component.feed.FeedEntryPollingConsumer
poll
 
Methods inherited from class org.apache.camel.impl.ScheduledPollConsumer
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
 
Methods inherited from class org.apache.camel.impl.DefaultConsumer
createUoW, doneUoW, getAsyncProcessor, getEndpoint, getExceptionHandler, getProcessor, getRoute, handleException, handleException, setExceptionHandler, setRoute, toString
 
Methods inherited from class org.apache.camel.support.ServiceSupport
doResume, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, resume, shutdown, start, stop, suspend
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 
Methods inherited from interface org.apache.camel.SuspendableService
isSuspended, resume, suspend
 
Methods inherited from interface org.apache.camel.Service
start, stop
 

Constructor Detail

RssEntryPollingConsumer

public RssEntryPollingConsumer(RssEndpoint endpoint,
                               org.apache.camel.Processor processor,
                               boolean filter,
                               Date lastUpdate,
                               boolean throttleEntries)
Method Detail

populateList

protected void populateList(Object feed)
                     throws Exception
Specified by:
populateList in class org.apache.camel.component.feed.FeedEntryPollingConsumer
Throws:
Exception

sortEntries

protected void sortEntries()

createFeed

protected Object createFeed()
                     throws Exception
Specified by:
createFeed in class org.apache.camel.component.feed.FeedPollingConsumer
Throws:
Exception

resetList

protected void resetList()
Specified by:
resetList in class org.apache.camel.component.feed.FeedEntryPollingConsumer

createEntryFilter

protected org.apache.camel.component.feed.EntryFilter createEntryFilter(Date lastUpdate)
Specified by:
createEntryFilter in class org.apache.camel.component.feed.FeedEntryPollingConsumer


Apache Camel