From 69310a7de3d963c2bf46250b0965a2c7e8532f1e Mon Sep 17 00:00:00 2001
From: zouyu <2723363702@qq.com>
Date: 星期二, 29 七月 2025 13:40:56 +0800
Subject: [PATCH] mqtt调整：实现订阅多个mqtt服务
---
cnas-device/src/main/java/com/ruoyi/device/mqtt/MQClient.java | 6 +++---
1 files changed, 3 insertions(+), 3 deletions(-)
diff --git a/cnas-device/src/main/java/com/ruoyi/device/mqtt/MQClient.java b/cnas-device/src/main/java/com/ruoyi/device/mqtt/MQClient.java
index 1c3c548..9f002c5 100644
--- a/cnas-device/src/main/java/com/ruoyi/device/mqtt/MQClient.java
+++ b/cnas-device/src/main/java/com/ruoyi/device/mqtt/MQClient.java
@@ -52,13 +52,13 @@
* WEB鏈嶅姟鍣ㄨ繛鎺QTT鏈嶅姟鍣ㄥ嚱鏁�
* @param mqttConfig yml涓璏QTT鐨勯厤缃�
*/
- public void connect(MQConfig mqttConfig) throws MqttException {
+ public void connect(DeviceMqttConfig mqttConfig) throws MqttException {
client = new MqttClient(mqttConfig.getUrl(), mqttConfig.getClientId(), new MemoryPersistence());
MqttConnectOptions options = getOption(mqttConfig.getUsername(), mqttConfig.getPassword(),
- mqttConfig.getTimeout(), mqttConfig.getKeepAlive());
+ mqttConfig.getTimeout(), mqttConfig.getKeepalive());
MQClient.setClient(client);
//杩炴帴澶辫触璋冪敤鍥炶皟鍑芥暟锛岄噸鏂拌繛鎺�
- client.setCallback(new MQCallback<Object>(this, mqttConfig));
+ client.setCallback(new MQCallback(this, mqttConfig));
if (!client.isConnected()) {
client.connect(options);
// 璁㈤槄涓婚
--
Gitblit v1.9.3