Bläddra i källkod

修改mqtt消息Qos值为0,测试丢失消息

james 1 månad sedan
förälder
incheckning
d5aeb27f0b

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

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