Skip to content

Commit fb5e78e

Browse files
committed
Expose isConnected to clients to help avoid race conditions
1 parent 240f82f commit fb5e78e

2 files changed

Lines changed: 17 additions & 0 deletions

File tree

org.eclipse.paho.client.mqttv3/src/main/java/org/eclipse/paho/client/mqttv3/MqttAsyncClient.java

Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -890,6 +890,16 @@ public boolean isConnected() {
890890
return comms.isConnected();
891891
}
892892

893+
894+
/*
895+
* (non-Javadoc)
896+
*
897+
* @see IMqttAsyncClient#isConnecting()
898+
*/
899+
public boolean isConnecting() {
900+
return comms.isConnecting();
901+
}
902+
893903
/*
894904
* (non-Javadoc)
895905
*

org.eclipse.paho.client.mqttv3/src/main/java/org/eclipse/paho/client/mqttv3/MqttClient.java

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -672,6 +672,13 @@ public boolean isConnected() {
672672
return aClient.isConnected();
673673
}
674674

675+
/* (non-Javadoc)
676+
* @see org.eclipse.paho.client.mqttv3.IMqttClient#isConnected()
677+
*/
678+
public boolean isConnecting() {
679+
return aClient.isConnecting();
680+
}
681+
675682
/* (non-Javadoc)
676683
* @see org.eclipse.paho.client.mqttv3.IMqttClient#setCallback(org.eclipse.paho.client.mqttv3.MqttCallback)
677684
*/

0 commit comments

Comments
 (0)