优化mqtt生产者取消消费者订阅

‘liusuyi’

2023-10-08 157c26f5188c7ed62a4547f7e3b5a5a3e3ed7729

 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));
    }

    /**