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 ;
                 }