org.maestro.client

Class MaestroReceiverClient

java.lang.Object

org.maestro.client.exchange.MaestroMqttClient

org.maestro.client.MaestroReceiverClient

All Implemented Interfaces:

MaestroClient, MaestroReceiver

public class MaestroReceiverClient
extends MaestroMqttClient
implements MaestroReceiver

Constructor Summary

Constructors

Constructor and Description
MaestroReceiverClient(String url, PeerInfo peerInfo, String id)

Method Summary

Modifier and Type	Method and Description
void	abnormalDisconnect() Publishes an abnormal disconnect notification message in the broker
String	getId()
void	getResponse(GetResponse getResponse) Publishes a get response as a reply to a get request
void	logResponse(File logFile, LocationType locationType, String hash) Sends log files via Maestro broker
void	notifyDrainComplete(boolean status, String message)
void	notifyFailure(String message) Publishes a test failure notification message in the broker
void	notifySuccess(String message) Publishes a test success notification message in the broker
void	pingResponse(MaestroNote note, long sec, long uSec) Publishes a ping response that takes into account a giver number of elapsed seconds/microseconds
void	replyInternalError(MaestroNote note, String message, String... args) Publishes an internal error reply in the Maestro broker
void	replyOk(MaestroNote note) Publishes a OK reply in the maestro broker
void	statsResponse(StatsResponse statsResponse) Publishes a stats response as a reply to a stats request

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

connect, disconnect, publish, publish, publish, subscribe, unsubscribe

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

MaestroReceiverClient

public MaestroReceiverClient(String url,
                             PeerInfo peerInfo,
                             String id)

Method Detail

getId

public String getId()

replyOk

public void replyOk(MaestroNote note)

Description copied from interface: MaestroReceiver

Publishes a OK reply in the maestro broker

Specified by:

replyOk in interface MaestroReceiver

Parameters:

note - the request note to correlate this response to

replyInternalError

public void replyInternalError(MaestroNote note,
                               String message,
                               String... args)

Description copied from interface: MaestroReceiver

Publishes an internal error reply in the Maestro broker

Specified by:

replyInternalError in interface MaestroReceiver

Parameters:

note - the request note to correlate this response to

message - the error message

args - the arguments to format the message

pingResponse

public void pingResponse(MaestroNote note,
                         long sec,
                         long uSec)

Description copied from interface: MaestroReceiver

Publishes a ping response that takes into account a giver number of elapsed seconds/microseconds

Specified by:

pingResponse in interface MaestroReceiver

Parameters:

note - the request note to correlate this response to

sec - Epoch seconds

uSec - Microseconds within the second

notifySuccess

public void notifySuccess(String message)

Description copied from interface: MaestroReceiver

Publishes a test success notification message in the broker

Specified by:

notifySuccess in interface MaestroReceiver

Parameters:

message - payload message

notifyFailure

public void notifyFailure(String message)

Description copied from interface: MaestroReceiver

Publishes a test failure notification message in the broker

Specified by:

notifyFailure in interface MaestroReceiver

Parameters:

message - payload message

abnormalDisconnect

public void abnormalDisconnect()

Description copied from interface: MaestroReceiver

Publishes an abnormal disconnect notification message in the broker

Specified by:

abnormalDisconnect in interface MaestroReceiver

statsResponse

public void statsResponse(StatsResponse statsResponse)

Publishes a stats response as a reply to a stats request

Parameters:

statsResponse - the stats response to publish

getResponse

public void getResponse(GetResponse getResponse)

Publishes a get response as a reply to a get request

Parameters:

getResponse - the get response to publish

logResponse

public void logResponse(File logFile,
                        LocationType locationType,
                        String hash)

Sends log files via Maestro broker

Parameters:

logFile - the log file to send

locationType - the location type

hash - the hash for the file being sent

notifyDrainComplete

public void notifyDrainComplete(boolean status,
                                String message)