public class DataRequestThread extends Thread
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
.Thread.State, Thread.UncaughtExceptionHandler
MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY
Constructor and Description |
---|
DataRequestThread(String channelName,
DataSource source,
TimeInterval interval) |
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) |
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
public DataRequestThread(String channelName, DataSource source, TimeInterval interval) throws Exception
Exception
public void addListener(DataRequestListener l)
DataRequestListener
.public void removeListener(DataRequestListener l)
DataRequestListener
.public TimeInterval getInterval()
public void setInterval(TimeInterval interval)
public String getChannelName()
public DataSource getSource()
public Timestamp getLastReceived()
public Integer getRequestID()
Copyright © 2015. All rights reserved.