org.apache.camel.component.feed
Class FeedEntryPollingConsumer

java.lang.Object
  extended by org.apache.camel.impl.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, Consumer, Service, SuspendableService
Direct Known Subclasses:
AtomEntryPollingConsumer, RssEntryPollingConsumer

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  List list
           
 
Fields inherited from class org.apache.camel.component.feed.FeedPollingConsumer
DEFAULT_CONSUMER_DELAY, endpoint
 
Fields inherited from class org.apache.camel.impl.DefaultConsumer
log
 
Constructor Summary
FeedEntryPollingConsumer(FeedEndpoint endpoint, Processor processor, boolean filter, Date lastUpdate)
           
 
Method Summary
protected abstract  EntryFilter createEntryFilter(Date lastUpdate)
           
 void poll()
          The polling method which is invoked periodically to poll this consumer
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
doStart, doStop, getDelay, getInitialDelay, getPollStrategy, getTimeUnit, isPollAllowed, isSuspended, isUseFixedDelay, resume, run, setDelay, setInitialDelay, setPollStrategy, setTimeUnit, setUseFixedDelay, suspend
 
Methods inherited from class org.apache.camel.impl.DefaultConsumer
getEndpoint, getExceptionHandler, getProcessor, handleException, setExceptionHandler, toString
 
Methods inherited from class org.apache.camel.impl.ServiceSupport
addChildService, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, removeChildService, start, stop
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 
Methods inherited from interface org.apache.camel.Service
start, stop
 

Field Detail

entryIndex

protected int entryIndex

entryFilter

protected EntryFilter entryFilter

list

protected List list
Constructor Detail

FeedEntryPollingConsumer

public FeedEntryPollingConsumer(FeedEndpoint endpoint,
                                Processor processor,
                                boolean filter,
                                Date lastUpdate)
Method Detail

poll

public void poll()
          throws Exception
Description copied from class: ScheduledPollConsumer
The polling method which is invoked periodically to poll this consumer

Overrides:
poll in class FeedPollingConsumer
Throws:
Exception - can be thrown if an exception occurred during polling

createEntryFilter

protected abstract EntryFilter createEntryFilter(Date lastUpdate)

resetList

protected abstract void resetList()

populateList

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


Copyright © 2007-2010 IONA Open Source Community. All Rights Reserved.