org.maestro.client.exchange

Class AbstractMaestroPeer<T extends MaestroNote>

java.lang.Object

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

Type Parameters:

T - TODO: configure LWT

All Implemented Interfaces:

org.eclipse.paho.client.mqttv3.MqttCallback, org.eclipse.paho.client.mqttv3.MqttCallbackExtended

Direct Known Subclasses:

MaestroCollector, MaestroWorkerManager

public abstract class AbstractMaestroPeer<T extends MaestroNote>
extends Object
implements org.eclipse.paho.client.mqttv3.MqttCallbackExtended

Is a base class that implements the basic operations of any peer connect to Maestro (not just senders and receivers). For example, a Collector instance that keeps reading the data from the Maestro broker is an specialization of this class as is the MaestroWorkerManager that handles the requests from the Maestro broker and manages the sender/receiver workers

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractMaestroPeer(org.eclipse.paho.client.mqttv3.MqttClient inboundEndPoint, PeerInfo peerInfo, MaestroNoteDeserializer<? extends T> deserializer)
protected	AbstractMaestroPeer(String url, PeerInfo peerInfo, MaestroNoteDeserializer<? extends T> deserializer)

Method Summary

Modifier and Type	Method and Description
void	connect()
void	connectComplete(boolean reconnect, String serverUri)
void	connectionLost(Throwable throwable)
void	deliveryComplete(org.eclipse.paho.client.mqttv3.IMqttDeliveryToken iMqttDeliveryToken)
void	disconnect()
String	getId()
protected PeerInfo	getPeerInfo()
boolean	isConnected()
abstract boolean	isRunning()
void	messageArrived(String s, org.eclipse.paho.client.mqttv3.MqttMessage mqttMessage)
protected abstract void	noteArrived(T note) The entry point for handling Maestro messages
void	reconnect(String[] topics)
void	subscribe(String[] topics)
void	subscribe(String topic, int qos)

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractMaestroPeer

protected AbstractMaestroPeer(String url,
                              PeerInfo peerInfo,
                              MaestroNoteDeserializer<? extends T> deserializer)
                       throws MaestroConnectionException

Throws:

MaestroConnectionException

AbstractMaestroPeer

protected AbstractMaestroPeer(org.eclipse.paho.client.mqttv3.MqttClient inboundEndPoint,
                              PeerInfo peerInfo,
                              MaestroNoteDeserializer<? extends T> deserializer)
                       throws MaestroConnectionException

Throws:

MaestroConnectionException

Method Detail

getPeerInfo

protected PeerInfo getPeerInfo()

getId

public String getId()

connectionLost

public void connectionLost(Throwable throwable)

Specified by:

connectionLost in interface org.eclipse.paho.client.mqttv3.MqttCallback

isConnected

public boolean isConnected()

deliveryComplete

public void deliveryComplete(org.eclipse.paho.client.mqttv3.IMqttDeliveryToken iMqttDeliveryToken)

Specified by:

deliveryComplete in interface org.eclipse.paho.client.mqttv3.MqttCallback

connect

public void connect()
             throws MaestroConnectionException

Throws:

MaestroConnectionException

reconnect

public void reconnect(String[] topics)

disconnect

public void disconnect()
                throws MaestroConnectionException

Throws:

MaestroConnectionException

subscribe

public void subscribe(String topic,
                      int qos)

subscribe

public void subscribe(String[] topics)
               throws MaestroConnectionException

Throws:

MaestroConnectionException

messageArrived

public void messageArrived(String s,
                           org.eclipse.paho.client.mqttv3.MqttMessage mqttMessage)

Specified by:

messageArrived in interface org.eclipse.paho.client.mqttv3.MqttCallback

connectComplete

public void connectComplete(boolean reconnect,
                            String serverUri)

Specified by:

connectComplete in interface org.eclipse.paho.client.mqttv3.MqttCallbackExtended

noteArrived

protected abstract void noteArrived(T note)
                             throws MaestroConnectionException

The entry point for handling Maestro messages

Parameters:

note - the note that arrived

Throws:

MaestroConnectionException - for Maestro related errors

isRunning

public abstract boolean isRunning()