添加异常处理

mhfire-service/src/main/java/com/bizmatics/mhfire/service/api/mhWater/OneCardApi.java

@@ -9,7 +9,6 @@ import org.springframework.beans.factory.annotation.Value;
 import org.springframework.boot.context.properties.ConfigurationProperties;
 import org.springframework.stereotype.Component;
 
-import java.io.IOException;
 import java.security.MessageDigest;
 import java.util.HashMap;
 import java.util.Map;
@@ -99,10 +98,10 @@ public class OneCardApi {
                 consumer.accept(data.asText());
                 log.info("闵行水系统接口-----调用成功");
             }else {
-                log.info("闵行水系统接口-----调用异常:"+arrNode.get("msg").asText());
+                log.error("闵行水系统接口-----调用异常:"+arrNode.get("msg").asText());
             }
-        } catch (IOException e) {
-            log.info("系统异常:"+e.getMessage());
+        } catch (Exception e) {
+            log.error("系统异常:"+e.getMessage());
         }
     }
 

mhfire-service/src/main/java/com/bizmatics/mhfire/service/config/mqtt/MqttInConfig.java

@@ -39,7 +39,7 @@ public class MqttInConfig {
                 mqttBaseConfig.mqttClientFactory(), mqttBaseConfig.getMsgTopic().split(","));
         adapter.setCompletionTimeout(mqttBaseConfig.getCompletionTimeout());
         adapter.setConverter(new DefaultPahoMessageConverter());
-        adapter.setQos(1);
+        adapter.setQos(2);
         adapter.setOutputChannel(mqttInputChannel());
         return adapter;
     }