|
@@ -106,7 +106,7 @@ public class IotSubscribe { |
|
|
// Session.AUTO_ACKNOWLEDGE: SDK自动ACK(推荐)。 |
|
|
// Session.AUTO_ACKNOWLEDGE: SDK自动ACK(推荐)。 |
|
|
log.warn("Befor connection.createSession"); |
|
|
log.warn("Befor connection.createSession"); |
|
|
Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); |
|
|
Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); |
|
|
log.warn("Befor connection.start"); |
|
|
|
|
|
|
|
|
log.debug("Befor connection.start"); |
|
|
connection.start(); |
|
|
connection.start(); |
|
|
|
|
|
|
|
|
// 创建Receiver连接。消费消息 |
|
|
// 创建Receiver连接。消费消息 |
|
|