Skip to content

Commit b0e3fbb

Browse files
committed
PR #469 - Updating v5 Client with same conState change
Signed-off-by: James Sutton <james.sutton@uk.ibm.com>
1 parent 39f5ec2 commit b0e3fbb

1 file changed

Lines changed: 1 addition & 0 deletions

File tree

  • org.eclipse.paho.mqttv5.client/src/main/java/org/eclipse/paho/mqttv5/client/internal

org.eclipse.paho.mqttv5.client/src/main/java/org/eclipse/paho/mqttv5/client/internal/ClientComms.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -602,6 +602,7 @@ public void disconnectForcibly(long quiesceTimeout, long disconnectTimeout, int
602602
*/
603603
public void disconnectForcibly(long quiesceTimeout, long disconnectTimeout, boolean sendDisconnectPacket,
604604
int reasonCode, MqttProperties disconnectProperties) throws MqttException {
605+
conState = DISCONNECTING;
605606
// Allow current inbound and outbound work to complete
606607
if (clientState != null) {
607608
clientState.quiesce(quiesceTimeout);

0 commit comments

Comments
 (0)