From 2c242c76c7c324eb92fb0b7f93c1fc6ed652f224 Mon Sep 17 00:00:00 2001
From: Nick O'Leary <nick.oleary@gmail.com>
Date: Fri, 17 Apr 2015 21:09:47 +0100
Subject: [PATCH] Add mqlight node error handler

---
 io/mqlight/mqlight.js   | 13 ++++++++++++-
 io/mqlight/package.json |  2 +-
 2 files changed, 13 insertions(+), 2 deletions(-)

diff --git a/io/mqlight/mqlight.js b/io/mqlight/mqlight.js
index 4015aaf9..75263f16 100644
--- a/io/mqlight/mqlight.js
+++ b/io/mqlight/mqlight.js
@@ -59,7 +59,7 @@ module.exports = function(RED) {
 
         if (node.serviceConfig) {
             if (node.serviceConfig.client) {
-            var recvClient = node.serviceConfig.client;
+                var recvClient = node.serviceConfig.client;
                 recvClient.on("started", function() {
                     recvClient.on("message", function(data, delivery) {
                         var msg = {
@@ -75,6 +75,11 @@ module.exports = function(RED) {
                         }
                         node.send(msg);
                     });
+                    recvClient.on("error", function(err) {
+                        if (err) {
+                            node.error(err.toString());
+                        }
+                    });
                     var subscribeCallback = function(err) {
                         if (err) {
                             node.error("Failed to subscribe: " + err);
@@ -129,6 +134,12 @@ module.exports = function(RED) {
                         });
                     });
                 });
+                sendClient.on("error", function(err) {
+                    if (err) {
+                        node.error(err.toString());
+                    }
+                });
+
                 sendClient.start();
 
                 node.on("close", function (done) {
diff --git a/io/mqlight/package.json b/io/mqlight/package.json
index 59b2ad92..9d5e9809 100644
--- a/io/mqlight/package.json
+++ b/io/mqlight/package.json
@@ -1,6 +1,6 @@
 {
     "name"          : "node-red-node-mqlight",
-    "version"       : "0.0.3",
+    "version"       : "0.0.4",
     "description"   : "A Node-RED node to send and receive message from IBM MQ Light",
     "dependencies"  : {
         "mqlight"   : "1.0.x"