org.apache.streams.local.test.providers

Class NumericMessageProvider

java.lang.Object

org.apache.streams.local.test.providers.NumericMessageProvider

All Implemented Interfaces:

Serializable, org.apache.streams.core.StreamsOperation, org.apache.streams.core.StreamsProvider

public class NumericMessageProvider
extends Object
implements org.apache.streams.core.StreamsProvider

Test StreamsProvider that sends out StreamsDatums numbered from 0 to numMessages.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
NumericMessageProvider(int numMessages)

Method Summary

Modifier and Type	Method and Description
void	cleanUp()
String	getId()
boolean	isRunning()
void	prepare(Object configurationObject)
org.apache.streams.core.StreamsResultSet	readCurrent()
org.apache.streams.core.StreamsResultSet	readNew(BigInteger sequence)
org.apache.streams.core.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

Constructor Detail

NumericMessageProvider

public NumericMessageProvider(int numMessages)

Method Detail

getId

public String getId()

Specified by:

getId in interface org.apache.streams.core.StreamsOperation

startStream

public void startStream()

Specified by:

startStream in interface org.apache.streams.core.StreamsProvider

readCurrent

public org.apache.streams.core.StreamsResultSet readCurrent()

Specified by:

readCurrent in interface org.apache.streams.core.StreamsProvider

readNew

public org.apache.streams.core.StreamsResultSet readNew(BigInteger sequence)

Specified by:

readNew in interface org.apache.streams.core.StreamsProvider

readRange

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

Specified by:

readRange in interface org.apache.streams.core.StreamsProvider

isRunning

public boolean isRunning()

Specified by:

isRunning in interface org.apache.streams.core.StreamsProvider

prepare

public void prepare(Object configurationObject)

Specified by:

prepare in interface org.apache.streams.core.StreamsOperation

cleanUp

public void cleanUp()

Specified by:

cleanUp in interface org.apache.streams.core.StreamsOperation