#

luxiaotao1123

2022-02-28 c3887c5c1624e5657655242ddfea52290ad87f6a

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
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());
    }
}