From 69f9a34ba602c4812caa1affc6c666a0d5df739e Mon Sep 17 00:00:00 2001
From: DengHuo <1091948791@qq.com>
Date: Mon, 1 Aug 2022 18:14:57 +0800
Subject: [PATCH] =?UTF-8?q?=E5=9C=A8=E8=87=AA=E5=8A=A8=E9=87=8D=E8=BF=9E?=
 =?UTF-8?q?=E9=80=89=E9=A1=B9=E4=B8=8B=EF=BC=8C=E8=A7=A3=E5=86=B3CommsCall?=
 =?UTF-8?q?back=E7=BA=BF=E7=A8=8B=E5=9C=A8=E8=BF=9E=E6=8E=A5=E4=B8=8AMQTT?=
 =?UTF-8?q?=E6=9C=8D=E5=8A=A1=E5=99=A8=EF=BC=8C=E5=BD=93=E6=9C=8D=E5=8A=A1?=
 =?UTF-8?q?=E5=99=A8=E6=96=AD=E5=BC=80=E5=90=8E=EF=BC=8C=E9=87=8D=E8=BF=9E?=
 =?UTF-8?q?=E7=9A=84=E7=BA=BF=E7=A8=8B=E4=B8=80=E7=9B=B4=E4=BC=9A=E5=9C=A8?=
 =?UTF-8?q?line:109=E7=A9=BA=E8=BD=AC=20while=20(!isRunning())=20{=20=20?=
 =?UTF-8?q?=20=20=20=20=20=20=20=20=20=20=20=20=20=20=20=20=20=20=20=20=20?=
 =?UTF-8?q?=20=20=20=20=20=20=20=20=20=20=20=20=20=20=20=20=20=20=20=20=20?=
 =?UTF-8?q?=20=20=20=20=20=20=20=20=20=20=20=20=09=09=09try=20{=20Thread.s?=
 =?UTF-8?q?leep(100);=20}=20catch=20(Exception=20e)=20{=20}=20=20=20=20=20?=
 =?UTF-8?q?=20=20=20=20=20=20=20=20=20=20=20=20=20=20=20=20=20=20=20=20=20?=
 =?UTF-8?q?=20=20=20=20=20=20=20=20=20=20=20=20=20=20=20=20=20=20=20=20=20?=
 =?UTF-8?q?=20=20=20=20=20=20=20=20=20=09=09}=20=E5=A6=82=E6=9E=9C?=
 =?UTF-8?q?=E9=87=8D=E8=BF=9E=E6=96=AD=E5=BC=80=E7=9A=84=E6=AC=A1=E6=95=B0?=
 =?UTF-8?q?=E8=BF=87=E5=A4=9A=EF=BC=8C=E6=9C=80=E7=BB=88=E9=80=A0=E6=88=90?=
 =?UTF-8?q?CommsCallback=E7=BA=BF=E7=A8=8B=E6=97=A0=E9=99=90=E5=A2=9E?=
 =?UTF-8?q?=E9=95=BF=E7=9A=84=E7=8A=B6=E5=86=B5=E3=80=82?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../org/eclipse/paho/client/mqttv3/internal/CommsCallback.java   | 1 +
 1 file changed, 1 insertion(+)

diff --git a/org.eclipse.paho.client.mqttv3/src/main/java/org/eclipse/paho/client/mqttv3/internal/CommsCallback.java b/org.eclipse.paho.client.mqttv3/src/main/java/org/eclipse/paho/client/mqttv3/internal/CommsCallback.java
index bcf2a5349..118cee8a4 100644
--- a/org.eclipse.paho.client.mqttv3/src/main/java/org/eclipse/paho/client/mqttv3/internal/CommsCallback.java
+++ b/org.eclipse.paho.client.mqttv3/src/main/java/org/eclipse/paho/client/mqttv3/internal/CommsCallback.java
@@ -128,6 +128,7 @@ public void stop() {
 			// @TRACE 700=stopping
 			log.fine(CLASS_NAME, methodName, "700");
 			synchronized (lifecycle) {
+				current_state = State.STOPPED;
 				target_state = State.STOPPED;
 			}
 			if (!Thread.currentThread().equals(callbackThread)) {