From 157c26f5188c7ed62a4547f7e3b5a5a3e3ed7729 Mon Sep 17 00:00:00 2001
From: ‘liusuyi’ <1951119284@qq.com>
Date: 星期日, 08 十月 2023 09:40:47 +0800
Subject: [PATCH] 优化mqtt生产者取消消费者订阅
---
src/main/java/com/ard/utils/hiksdk/service/impl/FMSGCallBack.java | 8 ++++----
1 files changed, 4 insertions(+), 4 deletions(-)
diff --git a/src/main/java/com/ard/utils/hiksdk/service/impl/FMSGCallBack.java b/src/main/java/com/ard/utils/hiksdk/service/impl/FMSGCallBack.java
index 62f68de..7deea3e 100644
--- a/src/main/java/com/ard/utils/hiksdk/service/impl/FMSGCallBack.java
+++ b/src/main/java/com/ard/utils/hiksdk/service/impl/FMSGCallBack.java
@@ -14,7 +14,7 @@
import com.ard.utils.hiksdk.domain.ExternalAlarmEventInfo;
import com.ard.utils.hiksdk.util.hikSdkUtil.HCNetSDK;
import com.ard.utils.other.DateUtils;
-import com.ard.utils.mqtt.MqttConsumer;
+import com.ard.utils.mqtt.MqttProducer;
import com.ard.utils.spring.SpringUtils;
import com.ard.utils.uuid.IdUtils;
import com.sun.jna.Pointer;
@@ -440,7 +440,7 @@
*/
private void publishMqtt(CameraEventInfo info) {
printLog(info);
- MqttConsumer.publish(2, false, "camera", JSON.toJSONString(info));
+ MqttProducer.publish(2, false, "camera", JSON.toJSONString(info));
}
/**
@@ -448,7 +448,7 @@
*/
private void publishMqtt(ExternalAlarmEventInfo info) {
printLog(info);
- MqttConsumer.publish(2, false, "external", JSON.toJSONString(info));
+ MqttProducer.publish(2, false, "external", JSON.toJSONString(info));
}
/**
@@ -456,7 +456,7 @@
*/
private void publishMqtt(AccessControlHostEventInfo info) {
printLog(info);
- MqttConsumer.publish(2, false, "accessControl", JSON.toJSONString(info));
+ MqttProducer.publish(2, false, "accessControl", JSON.toJSONString(info));
}
/**
--
Gitblit v1.9.3