package com.health.consultation.config;

import org.eclipse.paho.client.mqttv3.IMqttDeliveryToken;
import org.eclipse.paho.client.mqttv3.MqttCallbackExtended;
import org.eclipse.paho.client.mqttv3.MqttMessage;

public class Callback implements MqttCallbackExtended {
    /**
     * 连接完成
     * @param b
     * @param s
     */
    @Override
    public void connectComplete(boolean b, String s) {

    }

    /**
     * 连接丢失
     * @param throwable 抛出
     */
    @Override
    public void connectionLost(Throwable throwable) {

    }

    /**
     * 消息已到达
     * @param s
     * @param mqttMessage mqtt消息
     * @throws Exception
     */
    @Override
    public void messageArrived(String s, MqttMessage mqttMessage) throws Exception {

    }

    /**
     * 交货完成
     * @param iMqttDeliveryToken
     */
    @Override
    public void deliveryComplete(IMqttDeliveryToken iMqttDeliveryToken) {

    }
}