From 7adbe19a7df52ebe677dafc9147d93bcf86d4525 Mon Sep 17 00:00:00 2001 From: xce Date: Sat, 24 Jan 2026 19:11:04 +0800 Subject: [PATCH] =?UTF-8?q?mqtt=E6=9E=B6=E6=9E=84?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/agri/framework/interceptor/MqttMessageHandler.java | 6 +++--- 1 file changed, 3 insertions(+), 3 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 5145e25..732d286 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 @@ -240,9 +240,9 @@ public class MqttMessageHandler implements SmartLifecycle { } mqttBizPool.execute(() -> { - log.debug("mqttBizPool active={}, queue={}", - mqttBizPool.getActiveCount(), - mqttBizPool.getQueue().size()); + // log.debug("mqttBizPool active={}, queue={}", + // mqttBizPool.getActiveCount(), + // mqttBizPool.getQueue().size()); try { // 优化:显式指定UTF-8编码,避免乱码(JDK 8兼容) handleMessage(topic, payload);