Fix IOException

Ranjan-Dasgupta · Ranjan-Dasgupta · commit f72255b03c11 · 2020-02-10T22:04:55.000-06:00
Signed-off-by: Ranjan-Dasgupta &lt;Ranjan.Dasgupta@us.ibm.com&gt;
diff --git a/org.eclipse.paho.client.mqttv3/src/main/java/org/eclipse/paho/client/mqttv3/internal/CommsReceiver.java b/org.eclipse.paho.client.mqttv3/src/main/java/org/eclipse/paho/client/mqttv3/internal/CommsReceiver.java
@@ -165,10 +165,11 @@ public void run() {
 						if (message != null) {
 							// A new message has arrived
 							clientState.notifyReceivedMsg(message);
-						}  else {
+						}  
+                                                else {
                                                     // fix for bug 719
                                                     if (!clientComms.isConnected()) {
-                                                        throw new IOException(MqttException.REASON_CODE_CONNECTION_LOST);
+                                                         throw new IOException("Connection is lost.");
                                                     }
                                                 }
 					}

Original file line number	Diff line number	Diff line change
`@@ -165,10 +165,11 @@ public void run() {`
`165`	`165`	`if (message != null) {`
`166`	`166`	`// A new message has arrived`
`167`	`167`	`clientState.notifyReceivedMsg(message);`
`168`		`- } else {`
	`168`	`+ }`
	`169`	`+ else {`
`169`	`170`	`// fix for bug 719`
`170`	`171`	`if (!clientComms.isConnected()) {`
`171`		`- throw new IOException(MqttException.REASON_CODE_CONNECTION_LOST);`
	`172`	`+ throw new IOException("Connection is lost.");`
`172`	`173`	`}`
`173`	`174`	`}`
`174`	`175`	`}`