Skip to content

Commit 39f5ec2

Browse files
authored
Merge pull request #469 from Pitel/patch-1
Set conState when disconnecting forcibly
2 parents bbc3162 + 13478ed commit 39f5ec2

1 file changed

Lines changed: 1 addition & 0 deletions

File tree

  • org.eclipse.paho.client.mqttv3/src/main/java-templates/org/eclipse/paho/client/mqttv3/internal

org.eclipse.paho.client.mqttv3/src/main/java-templates/org/eclipse/paho/client/mqttv3/internal/ClientComms.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -530,6 +530,7 @@ public void disconnectForcibly(long quiesceTimeout, long disconnectTimeout) thro
530530
* @throws MqttException if an error occurs whilst disconnecting
531531
*/
532532
public void disconnectForcibly(long quiesceTimeout, long disconnectTimeout, boolean sendDisconnectPacket) throws MqttException {
533+
conState = DISCONNECTING;
533534
// Allow current inbound and outbound work to complete
534535
if (clientState != null) {
535536
clientState.quiesce(quiesceTimeout);

0 commit comments

Comments
 (0)