新增mq消费判断

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

@@ -208,9 +208,9 @@ public class MqttConfig {
     @ServiceActivator(inputChannel = CHANNEL_NAME_IN)
     public MessageHandler handler() {
         return message -> {
-//            if ("false".equals(isConsume)){
-//                return;
-//            }
+            if ("false".equals(isConsume)){
+                return;
+            }
             String topic = message.getHeaders().get("mqtt_receivedTopic").toString();
             String payload = message.getPayload().toString();
 //            mqttCallbackHandler.handle(topic, payload);