ISSUE_6 fix

iss2mqtt · Jun 21, 2017 · 8a12270 · 8a12270
1 parent 75fe589
commit 8a12270
Showing 1 changed file with 10 additions and 1 deletion.
diff --git a/M2Mqtt/MqttClient.cs b/M2Mqtt/MqttClient.cs
@@ -568,7 +568,16 @@ public byte Connect(string clientId,
             // start thread for receiving messages from broker
             Fx.StartThread(this.ReceiveThread);
 
-            MqttMsgConnack connack = (MqttMsgConnack)this.SendReceive(connect);
+            MqttMsgConnack connack = null;
+            try
+            {
+                connack = (MqttMsgConnack)this.SendReceive(connect);
+            }
+            catch (MqttCommunicationException)
+            {
+                this.isRunning = false;
+                throw;
+            }
 
             // if connection accepted, start keep alive timer and 
             if (connack.ReturnCode == MqttMsgConnack.CONN_ACCEPTED)