package com.zy.sc.common.mqtt;

import org.eclipse.paho.client.mqttv3.IMqttDeliveryToken;
import org.eclipse.paho.client.mqttv3.MqttCallback;
import org.eclipse.paho.client.mqttv3.MqttMessage;
import org.springframework.stereotype.Component;

/**
 * Created by vincent on 2021/9/15
 */
@Component
public class SubscribeListener implements MqttCallback {

    @Override
    public void connectionLost(Throwable throwable) {
        System.out.println("connectionLost");
    }

    @Override
    public void messageArrived(String topic, MqttMessage mqttMessage) throws Exception {
        System.out.println("topic:"+topic);
        System.out.println("Qos:"+mqttMessage.getQos());
        System.out.println("message content:"+new String(mqttMessage.getPayload()));
    }

    @Override
    public void deliveryComplete(IMqttDeliveryToken token) {
        System.out.println("deliveryComplete---------"+ token.isComplete());
    }
}