|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objecteu.reservoir.monitoring.core.AbstractPlaneInteracter
eu.reservoir.monitoring.core.AbstractDataConsumer
public abstract class AbstractDataConsumer
An AbstractDataConsumer interacts with the data plane, control plane, and the info plane and collects measurements. The measurements are passed on to all the Reporters added to the Consumer.
Constructor Summary | |
---|---|
AbstractDataConsumer()
Construct an AbstractDataConsumer. |
Method Summary | |
---|---|
void |
addReporter(Reporter l)
Add a Reporter. |
void |
beginThreadBody()
The code to run at the begining of the thread body. |
void |
clearReporters()
Clear away all the Reporters. |
void |
endThreadBody()
The code to run at the end of the thread body. |
int |
getReporterCount()
Count the Reporters. |
java.lang.Object[] |
getReporters()
List all Reporters. |
void |
removeReporter(Reporter l)
Remove a Reporter. |
Measurement |
report(Measurement m)
Receiver of a measurement, with the measurement. |
void |
run()
The thread body. |
PlaneInteracter |
setControlPlane(ControlPlane controlPlane)
Set the ControlPlane this is a delegate for. |
PlaneInteracter |
setDataPlane(DataPlane dataPlane)
Set the DataPlane this is a delegate for. |
PlaneInteracter |
setInfoPlane(InfoPlane infoPlane)
Set the InfoPlane this is a delegate for. |
Reporter |
setReporter(Reporter reporter)
Set the Reporter object. |
protected void |
startQueueHandlingThread()
Activate the forwarding from the queue to the Reporters by starting the thread. |
protected void |
stopQueueHandlingThread()
Deactivate the forwarding from the queue to the Reporters by stopping the thread. |
Methods inherited from class eu.reservoir.monitoring.core.AbstractPlaneInteracter |
---|
announce, connect, dennounce, disconnect, getControlPlane, getDataPlane, getInfoPlane, isConnected |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public AbstractDataConsumer()
Method Detail |
---|
protected void startQueueHandlingThread()
protected void stopQueueHandlingThread()
public PlaneInteracter setDataPlane(DataPlane dataPlane)
setDataPlane
in interface PlaneInteracter
setDataPlane
in class AbstractPlaneInteracter
public PlaneInteracter setControlPlane(ControlPlane controlPlane)
setControlPlane
in interface PlaneInteracter
setControlPlane
in class AbstractPlaneInteracter
public PlaneInteracter setInfoPlane(InfoPlane infoPlane)
setInfoPlane
in interface PlaneInteracter
setInfoPlane
in class AbstractPlaneInteracter
public Reporter setReporter(Reporter reporter)
public Measurement report(Measurement m)
report
in interface MeasurementReceiver
public void run()
run
in interface java.lang.Runnable
public void addReporter(Reporter l)
public void removeReporter(Reporter l)
public java.lang.Object[] getReporters()
public int getReporterCount()
public void clearReporters()
public void beginThreadBody()
public void endThreadBody()
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |