org.apache.streams.rss.provider

Class RssStreamProvider

java.lang.Object

org.apache.streams.rss.provider.RssStreamProvider

All Implemented Interfaces:

Serializable, StreamsOperation, StreamsProvider

public class RssStreamProvider
extends Object
implements StreamsProvider

RSS StreamsProvider that provides content from rss feeds in boilerpipe format

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
protected RssFeedScheduler	scheduler

Constructor Summary

Constructors

Constructor and Description
RssStreamProvider()
RssStreamProvider(boolean perpetual)
RssStreamProvider(RssStreamConfiguration config)
RssStreamProvider(RssStreamConfiguration config, boolean perpetual)

Method Summary

Modifier and Type	Method and Description
void	cleanUp()
String	getId()
protected RssFeedScheduler	getScheduler(BlockingQueue<StreamsDatum> queue)
boolean	isRunning()
static void	main(String[] args) To use from command line: Supply configuration similar to src/test/resources/rss.conf Launch using: mvn exec:java -Dexec.mainClass=org.apache.streams.rss.provider.RssStreamProvider -Dexec.args="rss.conf articles.json"
void	prepare(Object configurationObject)
StreamsResultSet	readCurrent()
StreamsResultSet	readNew(BigInteger sequence)
StreamsResultSet	readRange(org.joda.time.DateTime start, org.joda.time.DateTime end)
void	startStream()

Methods inherited from class java.lang.Object

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

Field Detail

scheduler

protected RssFeedScheduler scheduler

Constructor Detail

RssStreamProvider

public RssStreamProvider()

RssStreamProvider

public RssStreamProvider(boolean perpetual)

RssStreamProvider

public RssStreamProvider(RssStreamConfiguration config)

RssStreamProvider

public RssStreamProvider(RssStreamConfiguration config,
                         boolean perpetual)

Method Detail

getId

public String getId()

Specified by:

getId in interface StreamsOperation

startStream

public void startStream()

Specified by:

startStream in interface StreamsProvider

readCurrent

public StreamsResultSet readCurrent()

Specified by:

readCurrent in interface StreamsProvider

readNew

public StreamsResultSet readNew(BigInteger sequence)

Specified by:

readNew in interface StreamsProvider

readRange

public StreamsResultSet readRange(org.joda.time.DateTime start,
                                  org.joda.time.DateTime end)

Specified by:

readRange in interface StreamsProvider

isRunning

public boolean isRunning()

Specified by:

isRunning in interface StreamsProvider

prepare

public void prepare(Object configurationObject)

Specified by:

prepare in interface StreamsOperation

getScheduler

protected RssFeedScheduler getScheduler(BlockingQueue<StreamsDatum> queue)

cleanUp

public void cleanUp()

Specified by:

cleanUp in interface StreamsOperation

main

public static void main(String[] args)
                 throws Exception

To use from command line:

Supply configuration similar to src/test/resources/rss.conf

Launch using:

mvn exec:java -Dexec.mainClass=org.apache.streams.rss.provider.RssStreamProvider -Dexec.args="rss.conf articles.json"

Parameters:

args - args

Throws:

Exception - Exception