Package de.iip_ecosphere.platform.transport.spring.binder.mqttv5

Class MqttClient.Callback

java.lang.Object
de.iip_ecosphere.platform.transport.spring.binder.mqttv5.MqttClient.Callback
All Implemented Interfaces:
org.eclipse.paho.mqttv5.client.MqttCallback
Enclosing class:
MqttClient
private static class MqttClient.Callback extends Object implements org.eclipse.paho.mqttv5.client.MqttCallback
The internal MQTT reception callback.
Author:
Holger Eichelberger, SSE

  • Field Details

  • 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