org.maestro.agent.base

Class MaestroAgent

java.lang.Object

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

org.maestro.worker.common.MaestroWorkerManager

org.maestro.agent.base.MaestroAgent

All Implemented Interfaces:

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

public class MaestroAgent
extends MaestroWorkerManager
implements MaestroAgentEventListener, MaestroSenderEventListener, MaestroReceiverEventListener, MaestroInspectorEventListener

Agent for handle extension points. It implements everything that there is because it servers as a scriptable extension that can act based on any maestro command

Constructor Summary

Constructors

Constructor and Description
MaestroAgent(String maestroURL, PeerInfo peerInfo, MaestroDataServer dataServer) Constructor

Method Summary

Modifier and Type	Method and Description
void	handle(AbnormalDisconnect note) Abnormal disconnection handler
void	handle(AgentSourceRequest note)
void	handle(DrainRequest note)
void	handle(GetRequest note) Get request handler
void	handle(Halt note) Halt request handler
void	handle(LogRequest note)
void	handle(PingRequest note) Ping request handler
void	handle(RoleAssign note)
void	handle(RoleUnassign note)
void	handle(SetRequest note) Set request handler
void	handle(StartAgent note) Start agent handler
void	handle(StartInspector note) Start inspector handler
void	handle(StartWorker note)
void	handle(StatsRequest note) Stats request handler
void	handle(StopAgent note) Stop agent handler
void	handle(StopInspector note) Stop Inspector handler
void	handle(StopWorker note)
void	handle(TestFailedNotification note) Test failed notification handler
void	handle(TestSuccessfulNotification note) Test success notification handler
void	handle(UserCommand1Request note)

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

connect, getClient, getWorkerOptions, 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

MaestroAgent

public MaestroAgent(String maestroURL,
                    PeerInfo peerInfo,
                    MaestroDataServer dataServer)
             throws MaestroException

Constructor

Parameters:

maestroURL - maestro_broker URL

peerInfo - maestro peer information

dataServer - data server object

Throws:

MaestroException - if unable to create agent instance

Method Detail

handle

public void handle(StartInspector note)

Start inspector handler

Specified by:

handle in interface MaestroInspectorEventListener

Parameters:

note - StartInspector note

handle

public void handle(StopInspector note)

Stop Inspector handler

Specified by:

handle in interface MaestroInspectorEventListener

Parameters:

note - StopInspector note

handle

public void handle(StatsRequest note)

Stats request handler

Specified by:

handle in interface MaestroEventListener

Overrides:

handle in class MaestroWorkerManager

Parameters:

note - Stats note

handle

public void handle(Halt note)

Halt request handler

Specified by:

handle in interface MaestroEventListener

Overrides:

handle in class MaestroWorkerManager

Parameters:

note - Halt note

handle

public void handle(SetRequest note)

Set request handler

Specified by:

handle in interface MaestroEventListener

Overrides:

handle in class MaestroWorkerManager

Parameters:

note - Set note

handle

public void handle(TestFailedNotification note)

Test failed notification handler

Specified by:

handle in interface MaestroEventListener

Overrides:

handle in class MaestroWorkerManager

Parameters:

note - NotifyFail note

handle

public void handle(TestSuccessfulNotification note)

Test success notification handler

Specified by:

handle in interface MaestroEventListener

Overrides:

handle in class MaestroWorkerManager

Parameters:

note - NotifySuccess note

handle

public void handle(AbnormalDisconnect note)

Abnormal disconnection handler

Specified by:

handle in interface MaestroEventListener

Overrides:

handle in class MaestroWorkerManager

Parameters:

note - AbnormalDisconnect note

handle

public void handle(PingRequest note)
            throws MaestroConnectionException,
                   MalformedNoteException

Ping request handler

Specified by:

handle in interface MaestroEventListener

Overrides:

handle in class MaestroWorkerManager

Parameters:

note - Ping note

Throws:

MaestroConnectionException - if host is unreachable

MalformedNoteException - if note is malformed

handle

public void handle(GetRequest note)

Get request handler

Specified by:

handle in interface MaestroEventListener

Overrides:

handle in class MaestroWorkerManager

Parameters:

note - Get note

handle

public void handle(StartAgent note)

Start agent handler

Specified by:

handle in interface MaestroAgentEventListener

Parameters:

note - Start Agent note

handle

public void handle(StopAgent note)

Stop agent handler

Specified by:

handle in interface MaestroAgentEventListener

Parameters:

note - Stop Agent note

handle

public void handle(UserCommand1Request note)

Specified by:

handle in interface MaestroAgentEventListener

handle

public void handle(AgentSourceRequest note)

Specified by:

handle in interface MaestroAgentEventListener

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

handle

public void handle(RoleAssign note)

Specified by:

handle in interface MaestroEventListener

Overrides:

handle in class MaestroWorkerManager

handle

public void handle(RoleUnassign note)

Specified by:

handle in interface MaestroEventListener

Overrides:

handle in class MaestroWorkerManager