We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
2 parents 7c911f0 + f72255b commit 3cf991aCopy full SHA for 3cf991a
1 file changed
org.eclipse.paho.client.mqttv3/src/main/java/org/eclipse/paho/client/mqttv3/internal/CommsReceiver.java
@@ -165,10 +165,11 @@ public void run() {
165
if (message != null) {
166
// A new message has arrived
167
clientState.notifyReceivedMsg(message);
168
- } else {
+ }
169
+ else {
170
// fix for bug 719
171
if (!clientComms.isConnected()) {
- throw new MqttException(MqttException.REASON_CODE_CONNECTION_LOST);
172
+ throw new IOException("Connection is lost.");
173
}
174
175
0 commit comments