dekoh.portal.syndication.aggregator.core
Class FeedConsumer

java.lang.Object
  dekoh.portal.syndication.aggregator.core.FeedConsumer

public class FeedConsumer
extends Object

FeedConsumer is a ThreadPool based feed consumer. It will aggregate the feeds downloaded by FeedRetriever and notify the requesting aggregator about the status of aggregation.

Since:

Oct 24, 2007

Method Summary

Future

submit(List downloadedItems, AggregatorImpl aggregator) Submits the supplied downloaded item it to the thread pool for aggregation . These downloaded items will be aggregated whenever the threads in the pool are idle. Once all downloaded items are aggregated the aggregated feed will be written to file

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

submit

public Future submit(List downloadedItems,
                     AggregatorImpl aggregator)

Submits the supplied downloaded item it to the thread pool for aggregation .
These downloaded items will be aggregated whenever the threads in the pool are idle.
Once all downloaded items are aggregated the aggregated feed will be written to file

Parameters:

downloadedItems - List of downloaded item downloadedItems which will be aggregated

aggregator - aggregator whose downloaded items will be aggregated

Returns:

Future representing the status of the aggregation job