From 252e62ad13f545ca808a4b21982022f61b778fa2 Mon Sep 17 00:00:00 2001
From: jwds <1310840185@qq.com>
Date: Wed, 13 Sep 2023 16:54:25 +0800
Subject: [PATCH] Fix MqttClient(v3) waits after sending a qos=0 message

Signed-off-by: jwds <1310840185@qq.com>
---
 .../java/org/eclipse/paho/client/mqttv3/MqttClient.java     | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git a/org.eclipse.paho.client.mqttv3/src/main/java/org/eclipse/paho/client/mqttv3/MqttClient.java b/org.eclipse.paho.client.mqttv3/src/main/java/org/eclipse/paho/client/mqttv3/MqttClient.java
index 635568cf..57baa4c6 100644
--- a/org.eclipse.paho.client.mqttv3/src/main/java/org/eclipse/paho/client/mqttv3/MqttClient.java
+++ b/org.eclipse.paho.client.mqttv3/src/main/java/org/eclipse/paho/client/mqttv3/MqttClient.java
@@ -567,7 +567,11 @@ public void publish(String topic, byte[] payload,int qos, boolean retained) thro
 	 */
 	public void publish(String topic, MqttMessage message) throws MqttException,
 			MqttPersistenceException {
-		aClient.publish(topic, message, null, null).waitForCompletion(getTimeToWait());
+		if (message.getQos() == 0) {
+			getTopic(topic).publish(message);
+		} else {
+			aClient.publish(topic, message, null, null).waitForCompletion(getTimeToWait());
+		}
 	}
 
 	/**