org.apache.streams.rss.provider.perpetual

Class RssFeedScheduler

java.lang.Object

org.apache.streams.rss.provider.perpetual.RssFeedScheduler

All Implemented Interfaces:

Runnable

public class RssFeedScheduler
extends Object
implements Runnable

RssFeedScheduler launches threads to collect data from rss feeds.

Constructor Summary

Constructors

Constructor and Description
RssFeedScheduler(ExecutorService service, List<FeedDetails> feedDetailsList, BlockingQueue<StreamsDatum> dataQueue)
RssFeedScheduler(ExecutorService service, List<FeedDetails> feedDetailsList, BlockingQueue<StreamsDatum> dataQueue, int peroid) RssFeedScheduler constructor.

Method Summary

Modifier and Type	Method and Description
boolean	isComplete()
void	run()
void	scheduleFeeds() Schedule Feeds.
void	stop()

Methods inherited from class java.lang.Object

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

Constructor Detail

RssFeedScheduler

public RssFeedScheduler(ExecutorService service,
                        List<FeedDetails> feedDetailsList,
                        BlockingQueue<StreamsDatum> dataQueue)

RssFeedScheduler

public RssFeedScheduler(ExecutorService service,
                        List<FeedDetails> feedDetailsList,
                        BlockingQueue<StreamsDatum> dataQueue,
                        int peroid)

RssFeedScheduler constructor.

Parameters:

service - service

feedDetailsList - feedDetailsList

dataQueue - dataQueue

peroid - peroid

Method Detail

stop

public void stop()

isComplete

public boolean isComplete()

run

public void run()

Specified by:

run in interface Runnable

scheduleFeeds

public void scheduleFeeds()

Schedule Feeds.