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.getDataServer()
PeerSet	Maestro.getPeers() Gets all the peers connected to the test cluster
CompletableFuture<List<? extends MaestroNote>>	Maestro.halt()
CompletableFuture<List<? extends MaestroNote>>	Maestro.halt(String topic)
void	Maestro.logRequest(String topic, LocationType locationType, String typeName)
CompletableFuture<List<? extends MaestroNote>>	Maestro.pingRequest()
CompletableFuture<List<? extends MaestroNote>>	Maestro.pingRequest(String topic)
CompletableFuture<List<? extends MaestroNote>>	Maestro.roleAssign(String topic, Role role)
CompletableFuture<List<? extends MaestroNote>>	Maestro.roleUnassign(String topic)
CompletableFuture<List<? extends MaestroNote>>	Maestro.setBroker(String topic, String value)
CompletableFuture<List<? extends MaestroNote>>	Maestro.setFCL(String topic, int value)
CompletableFuture<List<? extends MaestroNote>>	Maestro.setMessageSize(String topic, long value)
CompletableFuture<List<? extends MaestroNote>>	Maestro.setMessageSize(String topic, String value)
CompletableFuture<List<? extends MaestroNote>>	Maestro.setParallelCount(String topic, int value)
CompletableFuture<List<? extends MaestroNote>>	Maestro.setRate(String topic, int value)
CompletableFuture<List<? extends MaestroNote>>	Maestro.sourceRequest(String topic, Source source)
CompletableFuture<List<? extends MaestroNote>>	Maestro.startAgent()
CompletableFuture<List<? extends MaestroNote>>	Maestro.startInspector(String value)
CompletableFuture<List<? extends MaestroNote>>	Maestro.startWorker(String topic, WorkerStartOptions options)
CompletableFuture<List<? extends MaestroNote>>	Maestro.statsRequest()
CompletableFuture<List<? extends MaestroNote>>	Maestro.statsRequest(String topic)
void	Maestro.stop() Stops maestro
CompletableFuture<List<? extends MaestroNote>>	Maestro.stopAgent()
CompletableFuture<List<? extends MaestroNote>>	Maestro.stopAll()
CompletableFuture<List<? extends MaestroNote>>	Maestro.stopInspector() Deprecated.
CompletableFuture<List<? extends MaestroNote>>	Maestro.stopInspector(String topic)
CompletableFuture<List<? extends MaestroNote>>	Maestro.stopWorker(String topic)
CompletableFuture<List<? extends MaestroNote>>	Maestro.userCommand(String topic, UserCommandData userCommandData)

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	AbstractMaestroExecutor.start(String[] topics, int connectionRetries, long retryDelay) Start running the executor
void	AbstractMaestroPeer.subscribe(String[] topics)

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

Constructor and Description
AbstractMaestroExecutor(AbstractMaestroPeer<? extends MaestroNote> maestroPeer) Constructor
AbstractMaestroPeer(org.eclipse.paho.client.mqttv3.MqttClient inboundEndPoint, PeerInfo peerInfo, MaestroNoteDeserializer<? extends T> deserializer)
AbstractMaestroPeer(String url, PeerInfo peerInfo, 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.getDataServer() Sends a get data server request
CompletableFuture<List<? extends MaestroNote>>	MaestroRequester.halt() Sends a halt request
void	MaestroRequester.logRequest(String topic, LocationType locationType, String typeName) Sends a log 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.roleAssign(String topic, Role role) Assign a role to one or more peers
CompletableFuture<List<? extends MaestroNote>>	MaestroRequester.roleUnassign(String topic) Unassign a role to one or more peers
CompletableFuture<List<? extends MaestroNote>>	MaestroRequester.setBroker(String topic, String value) Sends a set broker request
CompletableFuture<List<? extends MaestroNote>>	MaestroRequester.setFCL(String topic, int value) Sends a set fail-condition-latency (FCL) request
CompletableFuture<List<? extends MaestroNote>>	MaestroRequester.setMessageSize(String topic, long value) Sends a set message size request (this one can be used for fixed message sizes)
CompletableFuture<List<? extends MaestroNote>>	MaestroRequester.setMessageSize(String topic, 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(String topic, int value) Sends a set parallel count request
CompletableFuture<List<? extends MaestroNote>>	MaestroRequester.setRate(String topic, int value) Sends a set rate request
CompletableFuture<List<? extends MaestroNote>>	MaestroRequester.sourceRequest(String topic, Source source) Sends a source request to the agent (which causes it to download the given source)
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.startWorker(String topic, WorkerStartOptions options) Sends a start worker request
CompletableFuture<List<? extends MaestroNote>>	MaestroRequester.statsRequest() Sends a stats request
CompletableFuture<List<? extends MaestroNote>>	MaestroRequester.statsRequest(String topic) 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.stopInspector(String topic) Sends a stop inspector request
CompletableFuture<List<? extends MaestroNote>>	MaestroRequester.stopWorker(String topic) Sends a stop worker request
CompletableFuture<List<? extends MaestroNote>>	MaestroRequester.userCommand(String topic, UserCommandData userCommandData) Sends a user command 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(AbstractTestProfile testProfile, DistributionStrategy distributionStrategy) Start connected peers
void	AbstractTestExecutor.stopServices() Stop connected peers
protected void	AbstractTestExecutor.stopServices(DistributionStrategy distributionStrategy) 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<MaestroEventListener> note)