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

Constructor Summary

Constructors

Constructor and Description
LocalControllerSummaryReceiver(org.inria.myriads.snoozecommon.communication.NetworkAddress networkAddress, int timeOut, BlockingQueue<LocalControllerDataTransporter> dataQueue, StateMachine stateMachine, GroupManagerRepository repository) Constructor.

Method Summary

Methods

Modifier and Type	Method and Description
void	onDataArrival(Object data, String workerThreadId) Data event callback.
void	onFailure(String workerThreadId) The failure event callback.

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

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 address

timeOut - The timeout

dataQueue - The data queue

stateMachine - The state machine

repository - The group manager repository

Throws:

Exception

Method Detail

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 object

workerThreadId - The worker thread identifier