From 5c50a5f92ec234dcc3a77e9f64aca5a15f32fc64 Mon Sep 17 00:00:00 2001 From: linwl <304115325@qq.com> Date: Wed, 24 Feb 2021 18:26:24 +0800 Subject: [PATCH] =?UTF-8?q?=E5=A2=9E=E5=8A=A0=E8=B0=83=E8=AF=95=E4=BF=A1?= =?UTF-8?q?=E6=81=AF?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/com/telpo/iotgateway/server/IotSubscribe.java | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/src/main/java/com/telpo/iotgateway/server/IotSubscribe.java b/src/main/java/com/telpo/iotgateway/server/IotSubscribe.java index 48163db..dd1e300 100644 --- a/src/main/java/com/telpo/iotgateway/server/IotSubscribe.java +++ b/src/main/java/com/telpo/iotgateway/server/IotSubscribe.java @@ -97,20 +97,20 @@ public class IotSubscribe { Destination queue = (Destination)context.lookup("QUEUE"); // 创建连接。 - log.debug("Befor cf.createConnection"); + log.warn("Befor cf.createConnection"); Connection connection = cf.createConnection(userInfo, password); - log.debug("Befor connection.addConnectionListener"); + log.warn("Befor connection.addConnectionListener"); ((JmsConnection) connection).addConnectionListener(myJmsConnectionListener); // 创建会话。 // Session.CLIENT_ACKNOWLEDGE: 收到消息后，需要手动调用message.acknowledge()。 // Session.AUTO_ACKNOWLEDGE: SDK自动ACK（推荐）。 - log.debug("Befor connection.createSession"); + log.warn("Befor connection.createSession"); Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); - log.debug("Befor connection.start"); + log.warn("Befor connection.start"); connection.start(); // 创建Receiver连接。消费消息 - log.debug("Befor session.createConsumer"); + log.warn("Befor session.createConsumer"); MessageConsumer consumer = session.createConsumer(queue); // 设置消息侦听