mq异常日志

2025-11-24 16:49:31 +08:00
parent 7146128b4c
commit f8eae8d1dd
1 changed files with 1 additions and 2 deletions
--- a/cash-api/system-server/src/main/java/com/czg/mqtt/handler/MqttServerHandler.java
+++ b/cash-api/system-server/src/main/java/com/czg/mqtt/handler/MqttServerHandler.java
@@ -229,11 +229,10 @@ public class MqttServerHandler extends ChannelInboundHandlerAdapter {
        if ("con".equals(topic)) {
            // 延迟 2 秒执行
            SCHEDULER.schedule(() -> sendResponseToClient(ctx, "处理成功"), 2, TimeUnit.SECONDS);
-//            SCHEDULER.schedule(() -> deviceStatusManager.sendMqMsg(content), 0, TimeUnit.SECONDS);
            try {
                deviceStatusManager.sendMqMsg(content);
            } catch (Exception e) {
-                e.printStackTrace();
+                log.error("发送消息异常：{}", e.getMessage());
            }
        }