diff --git a/src/main/java/com/telpo/iotgateway/server/IotSubscribe.java b/src/main/java/com/telpo/iotgateway/server/IotSubscribe.java index dd1e300..c0ac59e 100644 --- a/src/main/java/com/telpo/iotgateway/server/IotSubscribe.java +++ b/src/main/java/com/telpo/iotgateway/server/IotSubscribe.java @@ -106,7 +106,7 @@ public class IotSubscribe { // Session.AUTO_ACKNOWLEDGE: SDK自动ACK(推荐)。 log.warn("Befor connection.createSession"); Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); - log.warn("Befor connection.start"); + log.debug("Befor connection.start"); connection.start(); // 创建Receiver连接。消费消息