From ef1e469fd3e885b9238bc1ef5e8d82b3a43bd55b Mon Sep 17 00:00:00 2001 From: liusuyi <13324259@qq.com> Date: 星期三, 29 十一月 2023 20:07:29 +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