org.inria.myriads.snoozenode.groupmanager.monitoring.receiver

Class GroupManagerSummaryReceiver

java.lang.Object

org.inria.myriads.snoozenode.tcpip.TCPDataReceiver

org.inria.myriads.snoozenode.groupmanager.monitoring.receiver.GroupManagerSummaryReceiver

All Implemented Interfaces:

Runnable, DataListener

public final class GroupManagerSummaryReceiver
extends TCPDataReceiver
implements DataListener

Group manager monitoring data receiver.

Author:

Eugen Feller

Constructor Summary

Constructors

Constructor and Description
GroupManagerSummaryReceiver(org.inria.myriads.snoozecommon.communication.NetworkAddress networkAddress, int timeOut, GroupLeaderRepository repository) Constructor.

Method Summary

Methods

Modifier and Type	Method and Description
void	onDataArrival(Object data, String workerThreadId) Data event callback.
void	onFailure(String workerThreadId) Handles the monitoring data timeout.

Methods inherited from class org.inria.myriads.snoozenode.tcpip.TCPDataReceiver

run, setHandler, terminate

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

GroupManagerSummaryReceiver

public GroupManagerSummaryReceiver(org.inria.myriads.snoozecommon.communication.NetworkAddress networkAddress,
                           int timeOut,
                           GroupLeaderRepository repository)
                            throws Exception

Constructor.

Parameters:

networkAddress - The network address

timeOut - The timeout

repository - The group leader repository

Throws:

Exception

Method Detail

onFailure

public void onFailure(String workerThreadId)

Handles the monitoring data timeout.

Specified by:

onFailure in interface DataListener

Parameters:

workerThreadId - The worker thread id

onDataArrival

public void onDataArrival(Object data,
                 String workerThreadId)

Data event callback.

Specified by:

onDataArrival in interface DataListener

Parameters:

data - The data object

workerThreadId - The worker thread identifier