From 768308ab47041062d9e97745099784acf297286b Mon Sep 17 00:00:00 2001
From: jiazx0107@163.com <jiazx0107@163.com>
Date: 星期三, 08 十一月 2023 17:45:37 +0800
Subject: [PATCH] 提交粮情测试协议和流程
---
src/main/java/com/fzzy/mqtt/MqttConsumerConfig.java | 6 +++++-
1 files changed, 5 insertions(+), 1 deletions(-)
diff --git a/src/main/java/com/fzzy/mqtt/MqttConsumerConfig.java b/src/main/java/com/fzzy/mqtt/MqttConsumerConfig.java
index b4c6f6c..ca83cb1 100644
--- a/src/main/java/com/fzzy/mqtt/MqttConsumerConfig.java
+++ b/src/main/java/com/fzzy/mqtt/MqttConsumerConfig.java
@@ -14,6 +14,9 @@
@Autowired
private MqttProperties mqttProperties;
+ @Autowired
+ private MqttConsumerCallBack mqttConsumerCallBack;
+
/**
* 瀹㈡埛绔璞�
*/
@@ -50,7 +53,8 @@
//璁剧疆閬楀槺娑堟伅鐨勮瘽棰橈紝鑻ュ鎴风鍜屾湇鍔″櫒涔嬮棿鐨勮繛鎺ユ剰澶栨柇寮�锛屾湇鍔″櫒灏嗗彂甯冨鎴风鐨勯仐鍢变俊鎭�
options.setWill("willTopic", (mqttProperties.getClientInId() + "涓庢湇鍔″櫒鏂紑杩炴帴").getBytes(), 0, false);
//璁剧疆鍥炶皟
- client.setCallback(new MqttConsumerCallBack());
+ // client.setCallback(new MqttConsumerCallBack());
+ client.setCallback(mqttConsumerCallBack);
client.connect(options);
//璁㈤槄涓婚
//娑堟伅绛夌骇锛屽拰涓婚鏁扮粍涓�涓�瀵瑰簲锛屾湇鍔＄灏嗘寜鐓ф寚瀹氱瓑绾х粰璁㈤槄浜嗕富棰樼殑瀹㈡埛绔帹閫佹秷鎭�
--
Gitblit v1.9.3