org.maestro.worker.common

Class ConcurrentWorkerManager

java.lang.Object

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

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)

Constructor Summary

Constructors

Constructor and Description
ConcurrentWorkerManager(String maestroURL, PeerInfo peerInfo, File logDir, 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(StartWorker note)
void	handle(StatsRequest note)
void	handle(StopWorker 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, handle, handle, handle, isRunning, noteArrived

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

connectComplete, connectionLost, deliveryComplete, disconnect, getId, getPeerInfo, isConnected, messageArrived, reconnect, 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,
                               PeerInfo peerInfo,
                               File logDir,
                               MaestroDataServer dataServer)

Constructor

Parameters:

maestroURL - Maestro URL

peerInfo - Peer information

logDir - test log directory

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(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

handle

public void handle(StartWorker note)

Specified by:

handle in interface MaestroEventListener

handle

public void handle(StopWorker note)

Specified by:

handle in interface MaestroEventListener