public class MQTTListener
extends java.lang.Object
implements org.fusesource.mqtt.client.Listener
addMQTTListener method. When
the MQTT event occurs, that object's appropriate
method is invoked.MQTTEvent| Constructor and Description |
|---|
MQTTListener(MQTTCommunication com)
Instantiates a new MQTT listener.
|
| Modifier and Type | Method and Description |
|---|---|
void |
onConnected() |
void |
onDisconnected() |
void |
onFailure(java.lang.Throwable value) |
void |
onPublish(org.fusesource.hawtbuf.UTF8Buffer topic,
org.fusesource.hawtbuf.Buffer payload,
java.lang.Runnable ack) |
public MQTTListener(MQTTCommunication com)
com - the compublic void onConnected()
onConnected in interface org.fusesource.mqtt.client.Listenerpublic void onDisconnected()
onDisconnected in interface org.fusesource.mqtt.client.Listenerpublic void onFailure(java.lang.Throwable value)
onFailure in interface org.fusesource.mqtt.client.Listenerpublic void onPublish(org.fusesource.hawtbuf.UTF8Buffer topic,
org.fusesource.hawtbuf.Buffer payload,
java.lang.Runnable ack)
onPublish in interface org.fusesource.mqtt.client.Listener