org.inria.myriads.snoozenode.localcontroller.monitoring.consumer
Class VirtualMachineMonitorDataConsumer

java.lang.Object
  org.inria.myriads.snoozenode.tcpip.TCPDataSender
      org.inria.myriads.snoozenode.localcontroller.monitoring.consumer.VirtualMachineMonitorDataConsumer

All Implemented Interfaces:

Runnable

public final class VirtualMachineMonitorDataConsumer
extends TCPDataSender
implements Runnable

Virtual machine monitor data consumer.

Author:

Eugen Feller

Constructor Summary

VirtualMachineMonitorDataConsumer(org.inria.myriads.snoozecommon.communication.localcontroller.LocalControllerDescription localController, org.inria.myriads.snoozecommon.communication.NetworkAddress groupManagerAddress, BlockingQueue<AggregatedVirtualMachineData> dataQueue, MonitoringThresholds monitoringThresholds, VirtualMachineMonitoringListener callback)
Constructor.

Method Summary

void	run() Run method.
void	terminate() Terminates the consumer.

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

close, send

Methods inherited from class java.lang.Object

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

Constructor Detail

VirtualMachineMonitorDataConsumer

public VirtualMachineMonitorDataConsumer(org.inria.myriads.snoozecommon.communication.localcontroller.LocalControllerDescription localController,
                                         org.inria.myriads.snoozecommon.communication.NetworkAddress groupManagerAddress,
                                         BlockingQueue<AggregatedVirtualMachineData> dataQueue,
                                         MonitoringThresholds monitoringThresholds,
                                         VirtualMachineMonitoringListener callback)
                                  throws Exception

Constructor.

Parameters:

localController - The local controller description

groupManagerAddress - The group manager address

dataQueue - The data queue

monitoringThresholds - The monitoring thresholds

callback - The monitoring service callback

Throws:

Exception - The exception

Method Detail

run

public void run()

Run method.

Specified by:

run in interface Runnable

terminate

public void terminate()

Terminates the consumer.