From b4ef1d354d11be2ecb03315848df3d6bfd4e5943 Mon Sep 17 00:00:00 2001
From: Nick O'Leary <nick.oleary@gmail.com>
Date: Wed, 19 Feb 2014 21:30:46 +0000
Subject: [PATCH] Catch mqtt socket write error after disconnect Part of #155

---
 nodes/core/io/lib/mqtt.js | 10 ++++++++--
 1 file changed, 8 insertions(+), 2 deletions(-)

diff --git a/nodes/core/io/lib/mqtt.js b/nodes/core/io/lib/mqtt.js
index 87356c792..e91b9526c 100644
--- a/nodes/core/io/lib/mqtt.js
+++ b/nodes/core/io/lib/mqtt.js
@@ -79,7 +79,10 @@ MQTTClient.prototype.connect = function(options) {
                         var now = (new Date()).getTime();
                         if (now - self.lastOutbound > self.options.keepalive*500 || now - self.lastInbound > self.options.keepalive*500) {
                            if (self.pingOutstanding) {
-                               self.client.disconnect();
+                              try {
+                                 self.client.disconnect();
+                              } catch (err) {
+                              }
                            } else {
                               self.lastOutbound = (new Date()).getTime();
                               self.lastInbound = (new Date()).getTime();
@@ -216,7 +219,10 @@ MQTTClient.prototype.disconnect = function() {
    var self = this;
    if (this.connected) {
        this.connected = false;
-       this.client.disconnect();
+       try {
+           this.client.disconnect();
+       } catch(err) {
+       }
    }
 }
 MQTTClient.prototype.isConnected = function() {