|
|
|
@ -40,7 +40,9 @@ public class MyMQTTCallback implements MqttCallback { |
|
|
|
|
//连接成功,重新订阅主题
|
|
|
|
|
log.warn("重新链接成功,重新订阅主题"); |
|
|
|
|
MqttClient client = MyMQTTClient.getClient(); |
|
|
|
|
client.subscribe("/psdc/devices/1672921261340/datas/report/#", 1); |
|
|
|
|
client.subscribe("/hwj1/dntd/datas/report/dataTimingReport", 1); |
|
|
|
|
client.subscribe("/hwj1/dntd/request/action/command", 1); |
|
|
|
|
client.subscribe("/hwj1/dntd/response/action/command", 1); |
|
|
|
|
log.warn("重新订阅成功"); |
|
|
|
|
return ; |
|
|
|
|
} |
|
|
|
|