org.diirt.datasource.timecache

Class DataRequestThread

java.lang.Object

java.lang.Thread

org.diirt.datasource.timecache.DataRequestThread

All Implemented Interfaces:

Runnable

public class DataRequestThread
extends Thread

Retrieves chunks from the specified DataSource, channel name and TimeInterval. Polls chunks from the source until the Timestamp of the last received Data is superior to the end of the defined TimeInterval.

Author:

Fred Arnaud (Sopra Group) - ITER

Nested Class Summary

Nested classes/interfaces inherited from class java.lang.Thread

Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor and Description
DataRequestThread(String channelName, DataSource source, TimeInterval interval)

Method Summary

Modifier and Type	Method and Description
void	addListener(DataRequestListener l) Add a DataRequestListener.
boolean	equals(Object obj)
String	getChannelName()
TimeInterval	getInterval()
Timestamp	getLastReceived()
Integer	getRequestID()
DataSource	getSource()
int	hashCode()
void	removeListener(DataRequestListener l) Remove a DataRequestListener.
void	run()
void	setInterval(TimeInterval interval)

Methods inherited from class java.lang.Thread

activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

DataRequestThread

public DataRequestThread(String channelName,
                         DataSource source,
                         TimeInterval interval)
                  throws Exception

Throws:

Exception

Method Detail

run

public void run()

Specified by:

run in interface Runnable

Overrides:

run in class Thread

addListener

public void addListener(DataRequestListener l)

Add a DataRequestListener.

removeListener

public void removeListener(DataRequestListener l)

Remove a DataRequestListener.

getInterval

public TimeInterval getInterval()

setInterval

public void setInterval(TimeInterval interval)

getChannelName

public String getChannelName()

getSource

public DataSource getSource()

getLastReceived

public Timestamp getLastReceived()

getRequestID

public Integer getRequestID()

hashCode

public int hashCode()

Overrides:

hashCode in class Object

equals

public boolean equals(Object obj)

Overrides:

equals in class Object