1. 调整mq结果

This commit is contained in:
andy 2025-04-10 08:32:42 +08:00
parent 6110548291
commit a899934904

View File

@ -33,6 +33,7 @@ public class MqttPublishMessage {
// 一旦此方法干净地返回消息就已被客户端接受发布当连接可用将在后台完成消息传递
token = mqttTopic.publish(mqttMessage);
token.waitForCompletion();
return token.getMessage();
} catch (MqttException e) {
e.printStackTrace();
}