Uses of Class
org.maestro.common.exceptions.MaestroConnectionException

Packages that use MaestroConnectionException

Package	Description
org.maestro.agent.base
org.maestro.client
org.maestro.client.exchange
org.maestro.common.client
org.maestro.exporter.main
org.maestro.tests
org.maestro.worker.common

Uses of MaestroConnectionException in org.maestro.agent.base

Methods in org.maestro.agent.base that throw MaestroConnectionException

Modifier and Type	Method and Description
void	MaestroAgent.handle(PingRequest note) Ping request handler

Uses of MaestroConnectionException in org.maestro.client

Methods in org.maestro.client that throw MaestroConnectionException

Modifier and Type	Method and Description
CompletableFuture<List<? extends MaestroNote>>	Maestro.flushRequest() Sends a flush request
CompletableFuture<List<? extends MaestroNote>>	Maestro.flushRequest(String topic) Sends a flush request
CompletableFuture<List<? extends MaestroNote>>	Maestro.getDataServer() Sends a get request
CompletableFuture<List<? extends MaestroNote>>	Maestro.halt() Sends a halt request
void	Maestro.logRequest(LocationType locationType, String typeName) Sends a log request
void	Maestro.logRequest(String topic, LocationType locationType, String typeName) Sends a log request
CompletableFuture<List<? extends MaestroNote>>	Maestro.pingRequest() Sends a ping request
CompletableFuture<List<? extends MaestroNote>>	Maestro.pingRequest(String topic) Sends a ping request
CompletableFuture<List<? extends MaestroNote>>	Maestro.setBroker(String value) Sends a set broker request
CompletableFuture<List<? extends MaestroNote>>	Maestro.setBroker(String topic, String value) Sends a set broker request
CompletableFuture<List<? extends MaestroNote>>	Maestro.setFCL(int value) Sends a set fail-condition-latency (FCL) request
CompletableFuture<List<? extends MaestroNote>>	Maestro.setLogLevel(String value) Sends a set log level request
CompletableFuture<List<? extends MaestroNote>>	Maestro.setLogLevel(String topic, String value) Sends a set log level request
CompletableFuture<List<? extends MaestroNote>>	Maestro.setMessageSize(long value) Sends a set message size request (this one can be used for fixed message sizes)
CompletableFuture<List<? extends MaestroNote>>	Maestro.setMessageSize(String value) Sends a set message size request (this one can be used for fixed or variable message sizes)
CompletableFuture<List<? extends MaestroNote>>	Maestro.setParallelCount(int value) Sends a set parallel count request
CompletableFuture<List<? extends MaestroNote>>	Maestro.setParallelCount(String topic, int value) Sends a set parallel count request
CompletableFuture<List<? extends MaestroNote>>	Maestro.setRate(int value) Sends a set rate request
CompletableFuture<List<? extends MaestroNote>>	Maestro.setRate(String topic, int value) Sends a set rate request
CompletableFuture<List<? extends MaestroNote>>	Maestro.setThrottle(int value) Sends a set throttle request
CompletableFuture<List<? extends MaestroNote>>	Maestro.setThrottle(String topic, int value) Sends a set throttle request
CompletableFuture<List<? extends MaestroNote>>	Maestro.sourceRequest(String sourceUrl, String branch) Sends a source request to the agent (which causes it to download the given source)
CompletableFuture<List<? extends MaestroNote>>	Maestro.startAgent() Sends a start agent request
CompletableFuture<List<? extends MaestroNote>>	Maestro.startAll(String inspectorName) Starts all of the receivers, senders and inspectors peers on the test cluster
CompletableFuture<List<? extends MaestroNote>>	Maestro.startInspector(String value) Sends a start inspector request
CompletableFuture<List<? extends MaestroNote>>	Maestro.startReceiver() Sends a start receiver request
CompletableFuture<List<? extends MaestroNote>>	Maestro.startSender() Sends a start sender request
CompletableFuture<List<? extends MaestroNote>>	Maestro.statsRequest() Sends a stats request
void	Maestro.stop() Stops maestro
CompletableFuture<List<? extends MaestroNote>>	Maestro.stopAgent() Sends a stop agent request
CompletableFuture<List<? extends MaestroNote>>	Maestro.stopAll() Sends a stop receiver request
CompletableFuture<List<? extends MaestroNote>>	Maestro.stopInspector() Sends a stop inspector request
CompletableFuture<List<? extends MaestroNote>>	Maestro.stopReceiver() Sends a stop receiver request
CompletableFuture<List<? extends MaestroNote>>	Maestro.stopSender() Sends a stop sender request
CompletableFuture<List<? extends MaestroNote>>	Maestro.userCommand(long option, String payload) Sends a user command request

Uses of MaestroConnectionException in org.maestro.client.exchange

Methods in org.maestro.client.exchange that throw MaestroConnectionException

Modifier and Type	Method and Description
void	AbstractMaestroPeer.connect()
void	MaestroMqttClient.connect() Connect to the maestro broker
void	AbstractMaestroPeer.disconnect()
void	MaestroMqttClient.disconnect() Disconnects from the maestro broker
protected abstract void	AbstractMaestroPeer.noteArrived(T note) The entry point for handling Maestro messages
void	MaestroMqttClient.publish(String topic, MaestroNote note) Publishes a message in the broker
protected void	MaestroMqttClient.publish(String topic, MaestroNote note, int qos, boolean retained) Publishes a message in the broker.
protected void	MaestroMqttClient.publish(String topic, MaestroNote note, int qos, boolean retained, MaestroNoteCallback postProcessCallback) Publishes a message in the broker.
void	AbstractMaestroExecutor.start(String[] topics) Start running the executor
void	AbstractMaestroPeer.subscribe(String[] topics)

Constructors in org.maestro.client.exchange that throw MaestroConnectionException

Constructor and Description
AbstractMaestroExecutor(AbstractMaestroPeer maestroPeer) Constructor
AbstractMaestroPeer(org.eclipse.paho.client.mqttv3.MqttClient inboundEndPoint, String clientName, MaestroNoteDeserializer<? extends T> deserializer)
AbstractMaestroPeer(String url, String clientName, MaestroNoteDeserializer<? extends T> deserializer)
MaestroCollector(String url) Constructor
MaestroCollectorExecutor(String url) Constructor

Uses of MaestroConnectionException in org.maestro.common.client

Methods in org.maestro.common.client that throw MaestroConnectionException

Modifier and Type	Method and Description
void	MaestroClient.connect() Connect to the maestro broker
void	MaestroClient.disconnect() Disconnects from the maestro broker
CompletableFuture<List<? extends MaestroNote>>	MaestroRequester.flushRequest() Deprecated.
CompletableFuture<List<? extends MaestroNote>>	MaestroRequester.flushRequest(String topic) Deprecated.
CompletableFuture<List<? extends MaestroNote>>	MaestroRequester.getDataServer() Sends a get request
CompletableFuture<List<? extends MaestroNote>>	MaestroRequester.halt() Sends a halt request
CompletableFuture<List<? extends MaestroNote>>	MaestroRequester.pingRequest() Sends a ping request
CompletableFuture<List<? extends MaestroNote>>	MaestroRequester.pingRequest(String topic) Sends a ping request
void	MaestroClient.publish(String topic, MaestroNote note) Publishes a message in the broker
CompletableFuture<List<? extends MaestroNote>>	MaestroRequester.setBroker(String value) Sends a set broker request
CompletableFuture<List<? extends MaestroNote>>	MaestroRequester.setBroker(String topic, String value) Sends a set broker request
CompletableFuture<List<? extends MaestroNote>>	MaestroRequester.setFCL(int value) Sends a set fail-condition-latency (FCL) request
CompletableFuture<List<? extends MaestroNote>>	MaestroRequester.setLogLevel(String value) Deprecated.
CompletableFuture<List<? extends MaestroNote>>	MaestroRequester.setLogLevel(String topic, String value) Sends a set log level request
CompletableFuture<List<? extends MaestroNote>>	MaestroRequester.setMessageSize(long value) Sends a set message size request (this one can be used for fixed message sizes)
CompletableFuture<List<? extends MaestroNote>>	MaestroRequester.setMessageSize(String value) Sends a set message size request (This one can be used for variable and fixed message sizes)
CompletableFuture<List<? extends MaestroNote>>	MaestroRequester.setParallelCount(int value) Sends a set parallel count request
CompletableFuture<List<? extends MaestroNote>>	MaestroRequester.setParallelCount(String topic, int value) Sends a set parallel count request
CompletableFuture<List<? extends MaestroNote>>	MaestroRequester.setRate(int value) Sends a set rate request
CompletableFuture<List<? extends MaestroNote>>	MaestroRequester.setRate(String topic, int value) Sends a set rate request
CompletableFuture<List<? extends MaestroNote>>	MaestroRequester.setThrottle(int value) Deprecated.
CompletableFuture<List<? extends MaestroNote>>	MaestroRequester.setThrottle(String topic, int value) Deprecated.
CompletableFuture<List<? extends MaestroNote>>	MaestroRequester.startAgent() Sends a start agent request
CompletableFuture<List<? extends MaestroNote>>	MaestroRequester.startInspector(String value) Sends a start inspector request
CompletableFuture<List<? extends MaestroNote>>	MaestroRequester.startReceiver() Sends a start receiver request
CompletableFuture<List<? extends MaestroNote>>	MaestroRequester.startSender() Sends a start sender request
CompletableFuture<List<? extends MaestroNote>>	MaestroRequester.statsRequest() Sends a stats request
void	MaestroRequester.stop() Stops maestro
CompletableFuture<List<? extends MaestroNote>>	MaestroRequester.stopAgent() Sends a stop agent request
CompletableFuture<List<? extends MaestroNote>>	MaestroRequester.stopInspector() Sends a stop inspector request
CompletableFuture<List<? extends MaestroNote>>	MaestroRequester.stopReceiver() Sends a stop receiver request
CompletableFuture<List<? extends MaestroNote>>	MaestroRequester.stopSender() Sends a stop sender request
CompletableFuture<List<? extends MaestroNote>>	MaestroRequester.userCommand(long option, String payload) Sends a agent general execution request

Uses of MaestroConnectionException in org.maestro.exporter.main

Methods in org.maestro.exporter.main that throw MaestroConnectionException

Modifier and Type	Method and Description
int	MaestroExporter.run(int port)

Uses of MaestroConnectionException in org.maestro.tests

Methods in org.maestro.tests that throw MaestroConnectionException

Modifier and Type	Method and Description
protected void	AbstractTestExecutor.startServices() Start connected peers
protected void	AbstractTestExecutor.startServices(AbstractTestProfile testProfile) Start connected peers
void	AbstractTestExecutor.stopServices() Stop connected peers

Uses of MaestroConnectionException in org.maestro.worker.common

Methods in org.maestro.worker.common that throw MaestroConnectionException

Modifier and Type	Method and Description
void	MaestroWorkerManager.connect()
void	MaestroWorkerManager.handle(PingRequest note)
protected void	MaestroWorkerManager.noteArrived(MaestroEvent note)