swarm.mqtt

Class RobotMqttClient

java.lang.Object

swarm.mqtt.RobotMqttClient

All Implemented Interfaces:

org.eclipse.paho.client.mqttv3.MqttCallback

public class RobotMqttClient
extends java.lang.Object
implements org.eclipse.paho.client.mqttv3.MqttCallback

Field Summary

Fields

Modifier and Type	Field and Description
java.util.Queue<MqttMsg>	inQueue
java.util.Queue<MqttMsg>	outQueue

Constructor Summary

Constructors

Constructor and Description
RobotMqttClient(java.lang.String server, int port, java.lang.String userName, java.lang.String password, java.lang.String channel)

Method Summary

Modifier and Type	Method and Description
void	connect()
void	connectionLost(java.lang.Throwable t)
void	deliveryComplete(org.eclipse.paho.client.mqttv3.IMqttDeliveryToken token)
MqttMsg	inQueue()
void	messageArrived(java.lang.String topic, org.eclipse.paho.client.mqttv3.MqttMessage message)
MqttMsg	outQueue()
void	publish(java.lang.String topic, java.lang.String body)
void	publish(java.lang.String topic, java.lang.String body, boolean retained)
void	publish(java.lang.String topic, java.lang.String body, int qos)
void	publish(java.lang.String topic, java.lang.String body, int qos, boolean retained)
void	subscribe(java.lang.String topic)

Methods inherited from class java.lang.Object

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

Field Detail

inQueue

public java.util.Queue<MqttMsg> inQueue

outQueue

public java.util.Queue<MqttMsg> outQueue

Constructor Detail

RobotMqttClient

public RobotMqttClient(java.lang.String server,
                       int port,
                       java.lang.String userName,
                       java.lang.String password,
                       java.lang.String channel)

Method Detail

connect

public void connect()

publish

public void publish(java.lang.String topic,
                    java.lang.String body)

publish

public void publish(java.lang.String topic,
                    java.lang.String body,
                    int qos)

publish

public void publish(java.lang.String topic,
                    java.lang.String body,
                    boolean retained)

publish

public void publish(java.lang.String topic,
                    java.lang.String body,
                    int qos,
                    boolean retained)

subscribe

public void subscribe(java.lang.String topic)

connectionLost

public void connectionLost(java.lang.Throwable t)

Specified by:

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

deliveryComplete

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

Specified by:

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

messageArrived

public void messageArrived(java.lang.String topic,
                           org.eclipse.paho.client.mqttv3.MqttMessage message)
                    throws java.lang.Exception

Specified by:

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

Throws:

java.lang.Exception

inQueue

public MqttMsg inQueue()

outQueue

public MqttMsg outQueue()