com.microsoft.azure.sdk.iot.device.transport.mqtt

Class Mqtt

java.lang.Object

com.microsoft.azure.sdk.iot.device.transport.mqtt.Mqtt

All Implemented Interfaces:

org.eclipse.paho.client.mqttv3.MqttCallback

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

Method Summary

Modifier and Type	Method and Description
void	connectionLost(java.lang.Throwable throwable) Event fired when the connection with the MQTT broker is lost.
void	deliveryComplete(org.eclipse.paho.client.mqttv3.IMqttDeliveryToken iMqttDeliveryToken) Event fired when the message arrived on the MQTT broker.
void	messageArrived(java.lang.String topic, org.eclipse.paho.client.mqttv3.MqttMessage mqttMessage) Event fired when the message arrived on the MQTT broker.
IotHubTransportMessage	receive() Method to receive messages on mqtt broker connection.

Methods inherited from class java.lang.Object

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

Method Detail

receive

public IotHubTransportMessage receive()

Method to receive messages on mqtt broker connection.

Returns:

a received message. It can be null

connectionLost

public void connectionLost(java.lang.Throwable throwable)

Event fired when the connection with the MQTT broker is lost.

Specified by:

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

Parameters:

throwable - Reason for losing the connection.

messageArrived

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

Event fired when the message arrived on the MQTT broker.

Specified by:

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

Parameters:

topic - the topic on which message arrived.

mqttMessage - the message arrived on the Mqtt broker.

deliveryComplete

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

Event fired when the message arrived on the MQTT broker.

Specified by:

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

Parameters:

iMqttDeliveryToken - the MqttDeliveryToken for which the message was successfully sent.