diff --git 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 index 87918269f..fa1170c67 100644 --- 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()); } }