mqtt架构

feasure
xce 2026-01-24 19:11:04 +08:00
parent c609b06781
commit 7adbe19a7d
1 changed files with 3 additions and 3 deletions

View File

@ -240,9 +240,9 @@ public class MqttMessageHandler implements SmartLifecycle {
} }
mqttBizPool.execute(() -> { mqttBizPool.execute(() -> {
log.debug("mqttBizPool active={}, queue={}", // log.debug("mqttBizPool active={}, queue={}",
mqttBizPool.getActiveCount(), // mqttBizPool.getActiveCount(),
mqttBizPool.getQueue().size()); // mqttBizPool.getQueue().size());
try { try {
// 优化显式指定UTF-8编码避免乱码JDK 8兼容 // 优化显式指定UTF-8编码避免乱码JDK 8兼容
handleMessage(topic, payload); handleMessage(topic, payload);