|
@@ -154,7 +154,7 @@ public class MqttDataConnector {
|
|
|
//0:最多一次,即:<=1;每个消息只发一次,也不会缓存下来。
|
|
|
//1:至少一次,即:>=1;一直发送确保消费者至少收到一次,发送失败会缓存下来。
|
|
|
//2:一次,即:=1 一直发送确保消费者只能收到一次;发送失败会缓存下来 。
|
|
|
- mqttMessage.setQos(1);
|
|
|
+ mqttMessage.setQos(0);
|
|
|
//消费者断开连接后是否接受离线消息
|
|
|
mqttMessage.setRetained(true);
|
|
|
mqttClient.publish(publicLiveTopic,mqttMessage);
|