From c8b6f74ecc29022a7f52a2ee35aa25eef3312f39 Mon Sep 17 00:00:00 2001
From: ‘liusuyi’ <1951119284@qq.com>
Date: 星期三, 25 十月 2023 17:09:15 +0800
Subject: [PATCH] 海康动态链接库集成

---
 src/main/java/com/ard/alarm/digitization/service/impl/DataBridgeServiceImpl.java |    4 ++--
 1 files changed, 2 insertions(+), 2 deletions(-)

diff --git a/src/main/java/com/ard/alarm/digitization/service/impl/DataBridgeServiceImpl.java b/src/main/java/com/ard/alarm/digitization/service/impl/DataBridgeServiceImpl.java
index 981f2a8..8b04e6f 100644
--- a/src/main/java/com/ard/alarm/digitization/service/impl/DataBridgeServiceImpl.java
+++ b/src/main/java/com/ard/alarm/digitization/service/impl/DataBridgeServiceImpl.java
@@ -4,7 +4,7 @@
 import com.ard.alarm.digitization.model.DataBridge;
 import com.ard.alarm.digitization.service.DataBridgeService;
 import com.ard.utils.jdbc.Query;
-import com.ard.utils.mqtt.MqttConsumer;
+import com.ard.utils.mqtt.MqttProducer;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.scheduling.annotation.Scheduled;
@@ -52,7 +52,7 @@
                     data.setWellNo(elem[0]);
                     data.setAlarmType(elem[1]);
                     data.setAlarmTime(elem[2]);
-                    MqttConsumer.publish(2, false, "digitization3", JSON.toJSONString(data));
+                    MqttProducer.publish(2, false, "digitization3", JSON.toJSONString(data));
                 }
             }
         } catch (Exception ex) {

--
Gitblit v1.9.3