From 16c4cfdbd38c6a68de24336fc0b6546583d1340b Mon Sep 17 00:00:00 2001
From: stone <827672943@qq.com>
Date: Tue, 4 Jul 2023 17:45:35 +0800
Subject: [PATCH] 111

---
 psdc-business/src/main/java/com/psdc/mqtt/MyMQTTCallback.java | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/psdc-business/src/main/java/com/psdc/mqtt/MyMQTTCallback.java b/psdc-business/src/main/java/com/psdc/mqtt/MyMQTTCallback.java
index 828220f..290a5eb 100644
--- a/psdc-business/src/main/java/com/psdc/mqtt/MyMQTTCallback.java
+++ b/psdc-business/src/main/java/com/psdc/mqtt/MyMQTTCallback.java
@@ -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 ;
                 }