From bc24edef6197a063a2e3d90d6f4455bd0bdd7b36 Mon Sep 17 00:00:00 2001
From: xce <mahuanran01@gamil.com>
Date: Fri, 16 Jan 2026 18:23:58 +0800
Subject: [PATCH] =?UTF-8?q?=E5=8E=BB=E6=8E=89=E6=97=A0=E7=94=A8=E6=97=A5?=
 =?UTF-8?q?=E5=BF=97?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../java/com/agri/framework/interceptor/MqttMessageHandler.java | 2 --
 1 file changed, 2 deletions(-)

diff --git a/agri-framework/src/main/java/com/agri/framework/interceptor/MqttMessageHandler.java b/agri-framework/src/main/java/com/agri/framework/interceptor/MqttMessageHandler.java
index e4ef9d1..396ae47 100644
--- a/agri-framework/src/main/java/com/agri/framework/interceptor/MqttMessageHandler.java
+++ b/agri-framework/src/main/java/com/agri/framework/interceptor/MqttMessageHandler.java
@@ -575,11 +575,9 @@ public class MqttMessageHandler implements SmartLifecycle {
     public void start() {
         log.info("开始监听");
         if (isRunning.compareAndSet(false, true)) {
-            log.info("开始监听111");
             try {
                 // 核心修改：无论是否已连接，都执行订阅（设置回调+订阅主题）
                 // 移除原有的if (!mqttClient.isConnected()) 判断
-                log.info("开始监听222");
                 subscribeTopics();
                 log.info("【MQTT生命周期】客户端启动成功（已设置回调+订阅主题）");
             } catch (MqttException e) {