org.maestro.agent.base

Class MaestroAgent

java.lang.Object

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

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

Field Summary

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

clientName

Constructor Summary

Constructors

Constructor and Description
MaestroAgent(String maestroURL, String role, String host, 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(FlushRequest note) Flush request handler
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(SetRequest note) Set request handler
void	handle(StartAgent note) Start agent handler
void	handle(StartInspector note) Start inspector handler
void	handle(StartReceiver note) Start receiver handler
void	handle(StartSender note) Start sender handler
void	handle(StatsRequest note) Stats request handler
void	handle(StopAgent note) Stop agent handler
void	handle(StopInspector note) Stop Inspector handler
void	handle(StopReceiver note) Stop receiver handler
void	handle(StopSender note) Stop sender handler
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, 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

MaestroAgent

public MaestroAgent(String maestroURL,
                    String role,
                    String host,
                    MaestroDataServer dataServer)
             throws MaestroException

Constructor

Parameters:

maestroURL - maestro_broker URL

role - agent

host - host address

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(StartReceiver note)

Start receiver handler

Specified by:

handle in interface MaestroReceiverEventListener

Parameters:

note - StartReceiver note

handle

public void handle(StartSender note)

Start sender handler

Specified by:

handle in interface MaestroSenderEventListener

Parameters:

note - StartSender note

handle

public void handle(StopInspector note)

Stop Inspector handler

Specified by:

handle in interface MaestroInspectorEventListener

Parameters:

note - StopInspector note

handle

public void handle(StopReceiver note)

Stop receiver handler

Specified by:

handle in interface MaestroReceiverEventListener

Parameters:

note - StopReceiver note

handle

public void handle(StopSender note)

Stop sender handler

Specified by:

handle in interface MaestroSenderEventListener

Parameters:

note - StopSender 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(FlushRequest note)

Flush request handler

Specified by:

handle in interface MaestroEventListener

Overrides:

handle in class MaestroWorkerManager

Parameters:

note - Flush 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