添加海康威视实时监控对接功能

Pu Zhibing

2025-05-28 a91f50ce8ce976743c11de98f9e3ed574bb3f78e

 ruoyi-service/ruoyi-dataInterchange/src/main/java/com/ruoyi/dataInterchange/util/mqtt/MqttInit.java

@@ -14,6 +14,7 @@
@Slf4j
@Component
public class MqttInit {

   @Autowired
   private MqttPahoMessageDrivenChannelAdapter messageDrivenChannelAdapter;
   
@@ -21,7 +22,9 @@
   public void init() {
      subscribeAllTopics();
   }


   public void subscribeAllTopics() {
      messageDrivenChannelAdapter.addTopic("artemis/event_msa_alarm/5201154049/admin");
      messageDrivenChannelAdapter.addTopic("artemis/event_msa_alarm/5201154049/admin", "artemis/event_msa_pic/5201301505/admin");
   }
}