From a899934904410ae34ef1a550b56b3190d1dcc032 Mon Sep 17 00:00:00 2001 From: andy <1042025947@qq.com> Date: Thu, 10 Apr 2025 08:32:42 +0800 Subject: [PATCH] =?UTF-8?q?1.=20=E8=B0=83=E6=95=B4mq=E7=BB=93=E6=9E=9C?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/evotech/hd/cloud/mqtt/config/MqttPublishMessage.java | 1 + 1 file changed, 1 insertion(+) diff --git a/cloud-manage-server/src/main/java/com/evotech/hd/cloud/mqtt/config/MqttPublishMessage.java b/cloud-manage-server/src/main/java/com/evotech/hd/cloud/mqtt/config/MqttPublishMessage.java index 14b2235..7b40c34 100644 --- a/cloud-manage-server/src/main/java/com/evotech/hd/cloud/mqtt/config/MqttPublishMessage.java +++ b/cloud-manage-server/src/main/java/com/evotech/hd/cloud/mqtt/config/MqttPublishMessage.java @@ -33,6 +33,7 @@ public class MqttPublishMessage { // 一旦此方法干净地返回,消息就已被客户端接受发布,当连接可用,将在后台完成消息传递。 token = mqttTopic.publish(mqttMessage); token.waitForCompletion(); + return token.getMessage(); } catch (MqttException e) { e.printStackTrace(); }