org.inria.myriads.snoozenode.groupmanager.monitoring.receiver
Class LocalControllerSummaryReceiver
java.lang.Object
org.inria.myriads.snoozenode.tcpip.TCPDataReceiver
org.inria.myriads.snoozenode.groupmanager.monitoring.receiver.LocalControllerSummaryReceiver
- All Implemented Interfaces:
- Runnable, DataListener
public final class LocalControllerSummaryReceiver
- extends TCPDataReceiver
- implements DataListener
Local controller monitoring data receiver.
- Author:
- Eugen Feller
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
LocalControllerSummaryReceiver
public LocalControllerSummaryReceiver(org.inria.myriads.snoozecommon.communication.NetworkAddress networkAddress,
int timeOut,
BlockingQueue<LocalControllerDataTransporter> dataQueue,
StateMachine stateMachine,
GroupManagerRepository repository)
throws Exception
- Constructor.
- Parameters:
networkAddress
- The network addresstimeOut
- The timeoutdataQueue
- The data queuestateMachine
- The state machinerepository
- The group manager repository
- Throws:
Exception
onFailure
public void onFailure(String workerThreadId)
- The failure event callback.
- Specified by:
onFailure
in interface DataListener
- Parameters:
workerThreadId
- The worker thread identifier
onDataArrival
public void onDataArrival(Object data,
String workerThreadId)
- Data event callback.
- Specified by:
onDataArrival
in interface DataListener
- Parameters:
data
- The data objectworkerThreadId
- The worker thread identifier
Copyright © 2012. All Rights Reserved.