frodovdr
/
node-red-nodes
mirror of https://github.com/node-red/node-red-nodes.git
1
0
Fork 0
Code Issues Releases Wiki Activity

Add mqlight node error handler

This commit is contained in:
Nick O'Leary 2015-04-17 21:09:47 +01:00
parent a886b663f8
commit 2c242c76c7
2 changed files with 13 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
io/mqlight/mqlight.js
View File

@ -59,7 +59,7 @@ module.exports = function(RED) {
if (node.serviceConfig) { if (node.serviceConfig) {
if (node.serviceConfig.client) { if (node.serviceConfig.client) {
var recvClient = node.serviceConfig.client; var recvClient = node.serviceConfig.client;
recvClient.on("started", function() { recvClient.on("started", function() {
recvClient.on("message", function(data, delivery) { recvClient.on("message", function(data, delivery) {
var msg = { var msg = {
@ -75,6 +75,11 @@ module.exports = function(RED) {
} }
node.send(msg); node.send(msg);
}); });
recvClient.on("error", function(err) {
if (err) {
node.error(err.toString());
}
});
var subscribeCallback = function(err) { var subscribeCallback = function(err) {
if (err) { if (err) {
node.error("Failed to subscribe: " + 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(); sendClient.start();
node.on("close", function (done) { node.on("close", function (done) {

2
io/mqlight/package.json
View File

@ -1,6 +1,6 @@
{ {
"name" : "node-red-node-mqlight", "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", "description" : "A Node-RED node to send and receive message from IBM MQ Light",
"dependencies" : { "dependencies" : {
"mqlight" : "1.0.x" "mqlight" : "1.0.x"