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

src/main/java/com/yunfeiyun/agmp/iots/core/mqtt/network/MqttPublisher.java

@@ -33,6 +33,10 @@ public class MqttPublisher {
     public void publish(String topic, String message) throws MqttException {
          CompletableFuture.runAsync(() -> {
             try {
+                if(topic.contains("qxz")){
+                    //TODO://暂时屏蔽气象站相关设备
+                    return;
+                }
                 log.info("发MQTT消息，topic:{}，message：{}",topic,message);
                 mqttClient.publish(topic, message.getBytes(), 0, false);
             }catch (Exception e){