From 8fb9d5dba9a1712f3500d24be15b369b8f6f3872 Mon Sep 17 00:00:00 2001 From: kerwincui <164770707@qq.com> Date: Mon, 30 May 2022 14:13:52 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BB=A3=E7=A0=81=E4=BC=98=E5=8C=96?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../src/main/java/com/ruoyi/iot/mqtt/EmqxClient.java | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/springboot/wumei-iot/src/main/java/com/ruoyi/iot/mqtt/EmqxClient.java b/springboot/wumei-iot/src/main/java/com/ruoyi/iot/mqtt/EmqxClient.java index 5d965bf8..c6e9ef31 100644 --- a/springboot/wumei-iot/src/main/java/com/ruoyi/iot/mqtt/EmqxClient.java +++ b/springboot/wumei-iot/src/main/java/com/ruoyi/iot/mqtt/EmqxClient.java @@ -79,7 +79,7 @@ public class EmqxClient { token.waitForCompletion(); }catch (Exception e){ logger.error("=====>>>>>mqtt连接失败 message={}",e.getMessage()); -// e.printStackTrace(); + e.printStackTrace(); } } } @@ -98,7 +98,7 @@ public class EmqxClient { logger.debug("====>>>mqtt客户端启动成功"); }catch (MqttException e){ logger.error("mqtt客户端连接错误 error={}",e.getMessage()); -// e.printStackTrace(); + e.printStackTrace(); } } } @@ -132,7 +132,6 @@ public class EmqxClient { token.waitForCompletion(); }catch (MqttException e){ logger.error("====>>>>断开mqtt连接发生错误 message={}",e.getMessage()); - throw new ServiceException("断开mqtt连接发生错误" + e.getMessage()); } } client = null;