org.apache.camel.component.atom
Class AtomEntryPollingConsumer

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.atom.AtomEntryPollingConsumer
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 AtomEntryPollingConsumer
extends FeedEntryPollingConsumer

Consumer to poll atom feeds and return each entry from the feed step by step.

Version:

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
AtomEntryPollingConsumer(AtomEndpoint endpoint, org.apache.camel.Processor processor, boolean filter, Date lastUpdate, boolean throttleEntries)
           
 
Method Summary
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.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

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 class FeedEntryPollingConsumer
Throws:
org.apache.abdera.parser.ParseException
IOException

createFeed

protected Object createFeed()
                     throws IOException
Specified by:
createFeed in class FeedPollingConsumer
Throws:
IOException

resetList

protected void resetList()
Specified by:
resetList in class FeedEntryPollingConsumer

createEntryFilter

protected EntryFilter createEntryFilter(Date lastUpdate)
Specified by:
createEntryFilter in class FeedEntryPollingConsumer


Apache Camel