Class PahoMqttV3TransportConnector.Callback

java.lang.Object
de.iip_ecosphere.platform.transport.mqttv3.PahoMqttV3TransportConnector.Callback
All Implemented Interfaces:
org.eclipse.paho.client.mqttv3.MqttCallback
Enclosing class:
PahoMqttV3TransportConnector

private class PahoMqttV3TransportConnector.Callback extends Object implements org.eclipse.paho.client.mqttv3.MqttCallback
The internal reception callback.
Author:
Holger Eichelberger, SSE
  • Constructor Details

    • Callback

      private Callback()
  • Method Details

    • connectionLost

      public void connectionLost(Throwable cause)
      Specified by:
      connectionLost in interface org.eclipse.paho.client.mqttv3.MqttCallback
    • messageArrived

      public void messageArrived(String topic, org.eclipse.paho.client.mqttv3.MqttMessage message) throws Exception
      Specified by:
      messageArrived in interface org.eclipse.paho.client.mqttv3.MqttCallback
      Throws:
      Exception
    • deliveryComplete

      public void deliveryComplete(org.eclipse.paho.client.mqttv3.IMqttDeliveryToken token)
      Specified by:
      deliveryComplete in interface org.eclipse.paho.client.mqttv3.MqttCallback