org.maestro.worker.common

Class MaestroWorkerManager

java.lang.Object

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

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

public abstract class MaestroWorkerManager
extends AbstractMaestroPeer<MaestroEvent<MaestroEventListener>>
implements MaestroEventListener

A base worker class that implements the most basic worker functionality

Constructor Summary

Constructors

Constructor and Description
MaestroWorkerManager(String maestroURL, PeerInfo peerInfo, 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(GetRequest note)
void	handle(GroupJoinRequest note)
void	handle(GroupLeaveRequest 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(RoleAssign note)
void	handle(RoleUnassign note)
void	handle(SetRequest note)
void	handle(StatsRequest note)
void	handle(TestFailedNotification note)
void	handle(TestSuccessfulNotification note)
boolean	isRunning()
protected void	noteArrived(MaestroEvent<MaestroEventListener> note) The entry point for handling Maestro messages

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

Methods inherited from interface org.maestro.client.notes.MaestroEventListener

handle, handle

Constructor Detail

MaestroWorkerManager

public MaestroWorkerManager(String maestroURL,
                            PeerInfo peerInfo,
                            MaestroDataServer dataServer)

Constructor

Parameters:

maestroURL - Maestro broker URL

peerInfo - Information about this peer

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

Throws:

MaestroConnectionException

isRunning

public boolean isRunning()

Specified by:

isRunning in class AbstractMaestroPeer<MaestroEvent<MaestroEventListener>>

noteArrived

protected final void noteArrived(MaestroEvent<MaestroEventListener> note)
                          throws MaestroConnectionException

Description copied from class: AbstractMaestroPeer

The entry point for handling Maestro messages

Specified by:

noteArrived in class AbstractMaestroPeer<MaestroEvent<MaestroEventListener>>

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(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 void handle(GroupJoinRequest note)

Specified by:

handle in interface MaestroEventListener

handle

public void handle(GroupLeaveRequest note)

Specified by:

handle in interface MaestroEventListener

handle

public void handle(RoleAssign note)

Specified by:

handle in interface MaestroEventListener

handle

public void handle(RoleUnassign note)

Specified by:

handle in interface MaestroEventListener

handle

public abstract void handle(LogRequest note)

Specified by:

handle in interface MaestroEventListener