org.maestro.worker.common

Class ConcurrentWorkerManager

java.lang.Object

org.maestro.client.exchange.AbstractMaestroPeer<MaestroEvent>

org.maestro.worker.common.MaestroWorkerManager

org.maestro.worker.common.ConcurrentWorkerManager

All Implemented Interfaces:

org.eclipse.paho.client.mqttv3.MqttCallback, org.eclipse.paho.client.mqttv3.MqttCallbackExtended, MaestroEventListener, MaestroReceiverEventListener, MaestroSenderEventListener

public class ConcurrentWorkerManager
extends MaestroWorkerManager
implements MaestroReceiverEventListener, MaestroSenderEventListener

A specialized worker manager that can manage concurrent test workers (ie.: senders/receivers)

Field Summary

Fields inherited from class org.maestro.client.exchange.AbstractMaestroPeer

clientName

Constructor Summary

Constructors

Constructor and Description
ConcurrentWorkerManager(String maestroURL, String role, String host, File logDir, Class<MaestroWorker> workerClass, MaestroDataServer dataServer) Constructor

Method Summary

Modifier and Type	Method and Description
void	handle(DrainRequest note)
void	handle(Halt note)
void	handle(LogRequest note)
void	handle(SetRequest note)
void	handle(StartReceiver note)
void	handle(StartSender note)
void	handle(StatsRequest note)
void	handle(StopReceiver note)
void	handle(StopSender note)
void	handle(TestFailedNotification note)
void	handle(TestSuccessfulNotification note)

Methods inherited from class org.maestro.worker.common.MaestroWorkerManager

connect, getClient, getWorkerOptions, handle, handle, handle, handle, handle, handle, isRunning, noteArrived

Methods inherited from class org.maestro.client.exchange.AbstractMaestroPeer

connectComplete, connectionLost, deliveryComplete, disconnect, getClientName, getId, isConnected, messageArrived, reconnect, setClientName, subscribe, subscribe

Methods inherited from class java.lang.Object

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

Constructor Detail

ConcurrentWorkerManager

public ConcurrentWorkerManager(String maestroURL,
                               String role,
                               String host,
                               File logDir,
                               Class<MaestroWorker> workerClass,
                               MaestroDataServer dataServer)

Constructor

Parameters:

maestroURL - Maestro URL

role - Worker Role

host - hostname for the worker

logDir - test log directory

workerClass - the class for the worker

dataServer - the data server instance

Method Detail

handle

public void handle(SetRequest note)

Specified by:

handle in interface MaestroEventListener

Overrides:

handle in class MaestroWorkerManager

handle

public void handle(Halt note)

Specified by:

handle in interface MaestroEventListener

Overrides:

handle in class MaestroWorkerManager

handle

public void handle(StartReceiver note)

Specified by:

handle in interface MaestroReceiverEventListener

handle

public void handle(StartSender note)

Specified by:

handle in interface MaestroSenderEventListener

handle

public void handle(StopReceiver note)

Specified by:

handle in interface MaestroReceiverEventListener

handle

public void handle(StopSender note)

Specified by:

handle in interface MaestroSenderEventListener

handle

public void handle(StatsRequest note)

Specified by:

handle in interface MaestroEventListener

Overrides:

handle in class MaestroWorkerManager

handle

public void handle(TestFailedNotification note)

Specified by:

handle in interface MaestroEventListener

Overrides:

handle in class MaestroWorkerManager

handle

public void handle(TestSuccessfulNotification note)

Specified by:

handle in interface MaestroEventListener

Overrides:

handle in class MaestroWorkerManager

handle

public void handle(LogRequest note)

Specified by:

handle in interface MaestroEventListener

Specified by:

handle in class MaestroWorkerManager

handle

public void handle(DrainRequest note)

Specified by:

handle in interface MaestroReceiverEventListener