public class PahoMqttAgentCallback
extends java.lang.Object
implements org.eclipse.paho.client.mqttv3.MqttCallback
IMqttAsyncClient
used by the PahoMqttAgent
.
It is in charge of dispatching received message to the different PahoMqttContext
.
Constructor and Description |
---|
PahoMqttAgentCallback(PahoMqttAgent mqttAgent) |
Modifier and Type | Method and Description |
---|---|
void |
connectionLost(java.lang.Throwable cause) |
void |
deliveryComplete(org.eclipse.paho.client.mqttv3.IMqttDeliveryToken token) |
void |
messageArrived(java.lang.String topic,
org.eclipse.paho.client.mqttv3.MqttMessage message) |
public PahoMqttAgentCallback(PahoMqttAgent mqttAgent)
mqttAgent
- the PahoMqttAgent
of this callbackpublic void connectionLost(java.lang.Throwable cause)
connectionLost
in interface org.eclipse.paho.client.mqttv3.MqttCallback
public void messageArrived(java.lang.String topic, org.eclipse.paho.client.mqttv3.MqttMessage message) throws java.lang.Exception
messageArrived
in interface org.eclipse.paho.client.mqttv3.MqttCallback
java.lang.Exception
public void deliveryComplete(org.eclipse.paho.client.mqttv3.IMqttDeliveryToken token)
deliveryComplete
in interface org.eclipse.paho.client.mqttv3.MqttCallback