org.maestro.worker.common

Class MaestroWorkerManager

java.lang.Object

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

org.maestro.worker.common.MaestroWorkerManager

All Implemented Interfaces:

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

Direct Known Subclasses:

ConcurrentWorkerManager, InspectorManager, MaestroAgent, VoidWorkerManager

public abstract class MaestroWorkerManager
extends AbstractMaestroPeer<MaestroEvent>
implements MaestroEventListener

A base worker class that implements the most basic worker functionality

Field Summary

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

clientName

Constructor Summary

Constructors

Constructor and Description
MaestroWorkerManager(String maestroURL, String role, String host, MaestroDataServer dataServer) Constructor

Method Summary

Modifier and Type	Method and Description
void	connect()
protected MaestroReceiverClient	getClient()
protected WorkerOptions	getWorkerOptions()
void	handle(AbnormalDisconnect note)
void	handle(DrainCompleteNotification note)
void	handle(FlushRequest note)
void	handle(GetRequest note)
void	handle(Halt note)
abstract void	handle(LogRequest note)
protected void	handle(LogRequest note, File logDir) Handle a log request note
void	handle(PingRequest note)
void	handle(SetRequest note)
void	handle(StatsRequest note)
void	handle(TestFailedNotification note)
void	handle(TestSuccessfulNotification note)
boolean	isRunning()
protected void	noteArrived(MaestroEvent note) The entry point for handling Maestro messages

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

MaestroWorkerManager

public MaestroWorkerManager(String maestroURL,
                            String role,
                            String host,
                            MaestroDataServer dataServer)

Constructor

Parameters:

maestroURL - Maestro broker URL

role - Worker role

host - hostname

dataServer - the data server instance

Method Detail

getWorkerOptions

protected WorkerOptions getWorkerOptions()

getClient

protected MaestroReceiverClient getClient()

connect

public void connect()
             throws MaestroConnectionException

Overrides:

connect in class AbstractMaestroPeer<MaestroEvent>

Throws:

MaestroConnectionException

isRunning

public boolean isRunning()

Specified by:

isRunning in class AbstractMaestroPeer<MaestroEvent>

noteArrived

protected final void noteArrived(MaestroEvent note)
                          throws MaestroConnectionException

Description copied from class: AbstractMaestroPeer

The entry point for handling Maestro messages

Specified by:

noteArrived in class AbstractMaestroPeer<MaestroEvent>

Parameters:

note - the note that arrived

Throws:

MaestroConnectionException - for Maestro related errors

handle

public void handle(StatsRequest note)

Specified by:

handle in interface MaestroEventListener

handle

public void handle(FlushRequest note)

Specified by:

handle in interface MaestroEventListener

handle

public void handle(Halt note)

Specified by:

handle in interface MaestroEventListener

handle

public void handle(SetRequest note)

Specified by:

handle in interface MaestroEventListener

handle

public void handle(TestFailedNotification note)

Specified by:

handle in interface MaestroEventListener

handle

public void handle(TestSuccessfulNotification note)

Specified by:

handle in interface MaestroEventListener

handle

public void handle(AbnormalDisconnect note)

Specified by:

handle in interface MaestroEventListener

handle

public void handle(PingRequest note)
            throws MaestroConnectionException,
                   MalformedNoteException

Specified by:

handle in interface MaestroEventListener

Throws:

MaestroConnectionException

MalformedNoteException

handle

public void handle(GetRequest note)

Specified by:

handle in interface MaestroEventListener

handle

public void handle(DrainCompleteNotification note)

Specified by:

handle in interface MaestroEventListener

handle

protected void handle(LogRequest note,
                      File logDir)

Handle a log request note

Parameters:

note - the note to handle

logDir - the log directory

handle

public abstract void handle(LogRequest note)

Specified by:

handle in interface MaestroEventListener