org.apache.camel.component.feed
Class FeedEntryPollingConsumer

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

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 class FeedPollingConsumer
Throws:
Exception

createEntryFilter

protected abstract EntryFilter createEntryFilter(Date lastUpdate)

resetList

protected abstract void resetList()

populateList

protected abstract void populateList(Object feed)
                              throws Exception
Throws:
Exception


Apache Camel