org.inria.myriads.snoozenode.groupmanager.monitoring
Class MonitoringFactory

java.lang.Object
  org.inria.myriads.snoozenode.groupmanager.monitoring.MonitoringFactory

public final class MonitoringFactory
extends Object

Monitoring factory.

Author:

Eugen Feller

Method Summary

static GroupManagerMonitoringService	newGroupManagerMonitoringService(GroupManagerRepository repository, int monitoringInterval) Creates a new group manager monitoring service.
static GroupManagerSummaryReceiver	newGroupManagerSummaryReceiver(org.inria.myriads.snoozecommon.communication.NetworkAddress networkAddress, int timeOut, GroupLeaderRepository repository) Creates a new group leader summary receiver.
static LocalControllerSummaryConsumer	newLocalControllerSummaryConsumer(BlockingQueue<LocalControllerDataTransporter> dataQueue, StateMachine stateMachine, GroupManagerRepository repository) Creates a new local controller summary information consumer.
static LocalControllerSummaryReceiver	newLocalControllerSummaryReceiver(org.inria.myriads.snoozecommon.communication.NetworkAddress networkAddress, int timeOut, BlockingQueue<LocalControllerDataTransporter> dataQueue, StateMachine stateMachine, GroupManagerRepository repository) Creates a new local controller monitoring data receiver.

Methods inherited from class java.lang.Object

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

Method Detail

newGroupManagerSummaryReceiver

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

Creates a new group leader summary receiver.

Parameters:

networkAddress - The network address

timeOut - The time out

repository - The repository

Returns:

The group leader monitoring data receiver

Throws:

Exception

newLocalControllerSummaryReceiver

public static LocalControllerSummaryReceiver newLocalControllerSummaryReceiver(org.inria.myriads.snoozecommon.communication.NetworkAddress networkAddress,
                                                                               int timeOut,
                                                                               BlockingQueue<LocalControllerDataTransporter> dataQueue,
                                                                               StateMachine stateMachine,
                                                                               GroupManagerRepository repository)
                                                                        throws Exception

Creates a new local controller monitoring data receiver.

Parameters:

networkAddress - The network address

timeOut - The timeout

dataQueue - The data queue

stateMachine - The state machine

repository - The group manager repository

Returns:

The summary data receiver

Throws:

Exception

newLocalControllerSummaryConsumer

public static LocalControllerSummaryConsumer newLocalControllerSummaryConsumer(BlockingQueue<LocalControllerDataTransporter> dataQueue,
                                                                               StateMachine stateMachine,
                                                                               GroupManagerRepository repository)
                                                                        throws Exception

Creates a new local controller summary information consumer.

Parameters:

dataQueue - The data queue

stateMachine - The state machine

repository - The repository

Returns:

The local controller monitoring data consumer

Throws:

Exception

newGroupManagerMonitoringService

public static GroupManagerMonitoringService newGroupManagerMonitoringService(GroupManagerRepository repository,
                                                                             int monitoringInterval)
                                                                      throws Exception

Creates a new group manager monitoring service.

Parameters:

repository - The group manager repository

monitoringInterval - The monitoring interval

Returns:

The group manager monitoring data sender

Throws:

Exception - The exception