暂时屏蔽mqtt控制

slope-modules/slope-detection/src/main/java/com/sckw/slope/detection/common/config/mqtt/MqttConfig.java

@@ -214,9 +214,9 @@ public class MqttConfig {
     public MessageHandler handler() {
         System.out.println("mqtt是否消费:" + isConsume);
         return message -> {
-            if (!"true".equals(isConsume)) {
-                return;
-            }
+//            if (!"true".equals(isConsume)) {
+//                return;
+//            }
             String topic = message.getHeaders().get("mqtt_receivedTopic").toString();
             String payload = message.getPayload().toString();
             mqttApiHandler.handle(topic, payload);