org.inria.myriads.snoozenode.groupmanager.monitoring.receiver
public final class GroupManagerSummaryReceiver extends TCPDataReceiver implements DataListener
Constructor and Description |
---|
GroupManagerSummaryReceiver(org.inria.myriads.snoozecommon.communication.NetworkAddress networkAddress,
int timeOut,
GroupLeaderRepository repository)
Constructor.
|
Modifier and Type | Method and Description |
---|---|
void |
onDataArrival(Object data,
String workerThreadId)
Data event callback.
|
void |
onFailure(String workerThreadId)
Handles the monitoring data timeout.
|
run, setHandler, terminate
public GroupManagerSummaryReceiver(org.inria.myriads.snoozecommon.communication.NetworkAddress networkAddress, int timeOut, GroupLeaderRepository repository) throws Exception
networkAddress
- The network addresstimeOut
- The timeoutrepository
- The group leader repositoryException
public void onFailure(String workerThreadId)
onFailure
in interface DataListener
workerThreadId
- The worker thread idpublic void onDataArrival(Object data, String workerThreadId)
onDataArrival
in interface DataListener
data
- The data objectworkerThreadId
- The worker thread identifierCopyright © 2013. All Rights Reserved.