程序包 com.cdkjframework.mqtt.consumer

类 CdkjMqttCallback

java.lang.Object
com.cdkjframework.mqtt.consumer.CdkjMqttCallback
所有已实现的接口:
org.eclipse.paho.client.mqttv3.MqttCallback
@Component public class CdkjMqttCallback extends Object implements org.eclipse.paho.client.mqttv3.MqttCallback

  • 构造器详细资料

    • CdkjMqttCallback

      public CdkjMqttCallback()

  • 方法详细资料

    • getClient

      public MqttConsumer getClient()
      构造方法

    • setClient

      public void setClient(MqttConsumer client)
      设置消息客户端

    • shutDown

      @PreDestroy public void shutDown()
      程序卸载

    • connectionLost

      public void connectionLost(Throwable cause)
      连接丢失
      指定者:
      connectionLost 在接口中 org.eclipse.paho.client.mqttv3.MqttCallback
      参数:
      cause - 异常数据

    • deliveryComplete

      public void deliveryComplete(org.eclipse.paho.client.mqttv3.IMqttDeliveryToken token)
      数据发送
      指定者:
      deliveryComplete 在接口中 org.eclipse.paho.client.mqttv3.MqttCallback
      参数:
      token - 令牌

    • messageArrived

      public void messageArrived(String topic, org.eclipse.paho.client.mqttv3.MqttMessage message)
      消息订阅
      指定者:
      messageArrived 在接口中 org.eclipse.paho.client.mqttv3.MqttCallback
      参数:
      topic - 主题
      message - 消息