frodovdr/node-red-nodes
1
0
Fork 0
mirror of https://github.com/node-red/node-red-nodes.git synced 2023-10-10 13:36:58 +02:00
Code Issues Releases Wiki Activity

Updates to Stomp to enable auto reconnect, and node.status indicators

Browse Source
This commit is contained in:
Dave C-J 2014-05-26 10:07:20 +01:00
parent a320ddce23
commit ae22efb270
1 changed files with 45 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

54
io/stomp/18-stomp.js
View File

@ -83,22 +83,42 @@ module.exports = function(RED) {
var node = this;
var msg = {topic:this.topic};
var closing = false;
node.client = new StompClient(node.host, node.port, node.userid, node.password, '1.0');
node.status({fill:"grey",shape:"ring",text:"connecting"},true);
node.client.connect(function(sessionId) {
node.log('subscribed to: '+node.topic);
node.client.subscribe(node.topic, function(body, headers) {
msg.payload = JSON.parse(body);
node.send(msg);
var doConnect = function() {
node.client.connect(function(sessionId) {
node.status({fill:"green",shape:"dot",text:"connected"},true);
node.log('subscribed to: '+node.topic);
node.client.subscribe(node.topic, function(body, headers) {
msg.payload = JSON.parse(body);
node.send(msg);
});
}, function(error) {
node.status({fill:"grey",shape:"dot",text:"error"},true);
node.warn(error);
});
}, function(error) { node.warn(error); });
}
node.client.on("error", function(error) {
node.log(error);
node.client.on("disconnect", function() {
node.status({fill:"red",shape:"ring",text:"disconnected"},true);
node.log("disconnected at "+Date().toString());
if (!closing) {
setTimeout( function () { doConnect(); }, 15000);
}
});
node.client.on("error", function(error) {
node.status({fill:"grey",shape:"dot",text:"error"},true);
node.log("error: "+error);
});
doConnect();
node.on("close", function(done) {
closing = true;
if (node.client) {
node.client.on("disconnect", function() {
done();
@ -124,10 +144,25 @@ module.exports = function(RED) {
var node = this;
var msg = {topic:this.topic};
var closing = false;
node.client = new StompClient(node.host, node.port, node.userid, node.password, '1.0');
node.status({fill:"grey",shape:"ring",text:"connecting"},true);
node.client.connect();
node.client.connect( function(sessionId) {
node.status({fill:"green",shape:"dot",text:"connected"},true);
}, function(error) {
node.status({fill:"grey",shape:"dot",text:"error"},true);
node.warn(error);
});
node.client.on("disconnect", function() {
node.status({fill:"red",shape:"ring",text:"disconnected"},true);
node.log("disconnected at "+Date().toString());
if (!closing) {
setTimeout( function () { node.client.connect(); }, 15000);
}
});
node.client.on("error", function(error) {
node.log(error);
@ -138,6 +173,7 @@ module.exports = function(RED) {
});
node.on("close", function(done) {
closing = true;
if (client) { client.disconnect(); }
});
}