소스 검색

暂时屏蔽订阅气象站相关设备

liuyaowen 1 년 전
부모
커밋
414ee39598
1개의 변경된 파일4개의 추가작업 그리고 0개의 파일을 삭제
  1. 4 0
      src/main/java/com/yunfeiyun/agmp/iots/core/mqtt/network/MqttCore.java

+ 4 - 0
src/main/java/com/yunfeiyun/agmp/iots/core/mqtt/network/MqttCore.java

@@ -238,6 +238,10 @@ public class MqttCore {
         if (getClient().isConnected()) {
         if (getClient().isConnected()) {
             // 如果此mqtt已经建立了连接,则正常订阅
             // 如果此mqtt已经建立了连接,则正常订阅
             for (String topic : topics) {
             for (String topic : topics) {
+                if(topic.contains("qxz")){
+                    //TODO://暂时屏蔽气象站相关设备
+                    continue;
+                }
                 getClient().subscribe(topic);
                 getClient().subscribe(topic);
                 log.info("[MQTT] {} 连接已建立 追加订阅主题 {}", cfgYf.getDeviceType(), topic);
                 log.info("[MQTT] {} 连接已建立 追加订阅主题 {}", cfgYf.getDeviceType(), topic);
             }
             }