修改mqtt订阅qos值改为2

data-transfer/data-transfer-biz/src/main/java/com/usky/transfer/service/config/mqtt/MqttInConfig.java

@@ -49,8 +49,7 @@ public class MqttInConfig {
                 mqttBaseConfig.mqttClientFactory(), tops);
         adapter.setCompletionTimeout(mqttBaseConfig.getCompletionTimeout());
         adapter.setConverter(new DefaultPahoMessageConverter());
-        //adapter.setQos(2);
-        adapter.setQos(0);
+        adapter.setQos(2);
         adapter.setOutputChannel(mqttInputChannel());
         return adapter;
     }