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