org.apache.streams.moreover

Class MoreoverProviderTask

java.lang.Object

org.apache.streams.moreover.MoreoverProviderTask

All Implemented Interfaces:

Runnable

public class MoreoverProviderTask
extends Object
implements Runnable

Task that pulls from the Morever API on behalf of MoreoverProvider.

Field Summary

Fields

Modifier and Type	Field and Description
static int	LATENCY
static int	REQUIRED_LATENCY

Constructor Summary

Constructors

Constructor and Description
MoreoverProviderTask(String apiId, String apiKey, Queue<StreamsDatum> results, String lastSequence) MoreoverProviderTask constructor.

Method Summary

Modifier and Type	Method and Description
void	run()

Methods inherited from class java.lang.Object

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

Field Detail

LATENCY

public static final int LATENCY

See Also:

Constant Field Values

REQUIRED_LATENCY

public static final int REQUIRED_LATENCY

See Also:

Constant Field Values

Constructor Detail

MoreoverProviderTask

public MoreoverProviderTask(String apiId,
                            String apiKey,
                            Queue<StreamsDatum> results,
                            String lastSequence)

MoreoverProviderTask constructor.

Parameters:

apiId - apiId

apiKey - apiKey

results - results

lastSequence - lastSequence

Method Detail

run

public void run()

Specified by:

run in interface Runnable