Package de.iip_ecosphere.platform.connectors.mqttv5

Class PahoMqttv5Connector.Callback

java.lang.Object

de.iip_ecosphere.platform.connectors.mqttv5.PahoMqttv5Connector.Callback

All Implemented Interfaces:

org.eclipse.paho.mqttv5.client.MqttCallback

Enclosing class:

PahoMqttv5Connector<CO,CI>

private class PahoMqttv5Connector.Callback
extends Object
implements org.eclipse.paho.mqttv5.client.MqttCallback

The internal reception callback.

Author:

Holger Eichelberger, SSE

Constructor Summary

Constructors

Modifier	Constructor	Description
private	Callback()

Method Summary

Modifier and Type	Method	Description
void	authPacketArrived(int reasonCode, org.eclipse.paho.mqttv5.common.packet.MqttProperties properties)
void	connectComplete(boolean reconnect, String serverURI)
void	deliveryComplete(org.eclipse.paho.mqttv5.client.IMqttToken token)
void	disconnected(org.eclipse.paho.mqttv5.client.MqttDisconnectResponse disconnectResponse)
void	messageArrived(String topic, org.eclipse.paho.mqttv5.common.MqttMessage message)
void	mqttErrorOccurred(org.eclipse.paho.mqttv5.common.MqttException exception)

Methods inherited from class java.lang.Object

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

Constructor Details

Callback

private Callback()

Method Details

messageArrived

public void messageArrived(String topic,
 org.eclipse.paho.mqttv5.common.MqttMessage message)
                    throws Exception

Specified by:

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

Throws:

Exception

disconnected

public void disconnected(org.eclipse.paho.mqttv5.client.MqttDisconnectResponse disconnectResponse)

Specified by:

disconnected in interface org.eclipse.paho.mqttv5.client.MqttCallback

mqttErrorOccurred

public void mqttErrorOccurred(org.eclipse.paho.mqttv5.common.MqttException exception)

Specified by:

mqttErrorOccurred in interface org.eclipse.paho.mqttv5.client.MqttCallback

deliveryComplete

public void deliveryComplete(org.eclipse.paho.mqttv5.client.IMqttToken token)

Specified by:

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

connectComplete

public void connectComplete(boolean reconnect,
 String serverURI)

Specified by:

connectComplete in interface org.eclipse.paho.mqttv5.client.MqttCallback

authPacketArrived

public void authPacketArrived(int reasonCode,
 org.eclipse.paho.mqttv5.common.packet.MqttProperties properties)

Specified by:

authPacketArrived in interface org.eclipse.paho.mqttv5.client.MqttCallback