frodovdr/node-red-nodes
1
0
Fork 0
mirror of https://github.com/node-red/node-red-nodes.git synced 2025-03-01 10:37:43 +00:00
Code Issues Packages Projects Releases Wiki Activity

Improvements & bugfixes to shared connection

Browse Source
This commit is contained in:
Olivier Verhaegen 2023-04-12 14:12:14 +02:00 committed by GitHub
parent 0c52d6b8be
commit 1a0d1ce173
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 40 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -17,6 +17,7 @@ module.exports = function(RED) {
this.username = this.credentials.user;
this.password = this.credentials.password;
this.clientConnection = null;
this.connected = false;
}
RED.nodes.registerType("stomp-server",StompServerNode,{
credentials: {
@ -66,15 +67,18 @@ module.exports = function(RED) {
node.client.on("connect", function() {
node.status({fill:"green",shape:"dot",text:"connected"});
node.serverConfig.connected = true;
});
node.client.on("reconnecting", function() {
node.status({fill:"red",shape:"ring",text:"reconnecting"});
node.warn("reconnecting");
node.serverConfig.connected = false;
});
node.client.on("reconnect", function() {
node.status({fill:"green",shape:"dot",text:"connected"});
node.serverConfig.connected = true;
});
node.client.on("error", function(error) {
@ -82,8 +86,10 @@ module.exports = function(RED) {
node.warn(error);
});
// Connect to server if needed and subscribe
node.status({fill:"grey",shape:"ring",text:"connecting"});
node.client.connect(function(sessionId) {
function subscribe() {
node.log('subscribing to: '+node.topic);
node.client.subscribe(node.topic, node.subscribeHeaders, function(body, headers) {
var newmsg={"headers":headers,"topic":node.topic}
@ -95,10 +101,19 @@ module.exports = function(RED) {
}
node.send(newmsg);
});
}, function(error) {
node.status({fill:"grey",shape:"dot",text:"error"});
node.warn(error);
});
}
if (!node.server.connected) {
node.client.connect(function(sessionId) {
subscribe();
}, function(error) {
node.status({fill:"grey",shape:"dot",text:"error"});
node.warn(error);
});
} else {
subscribe();
}
node.on("close", function(done) {
if (node.client) {
@ -141,15 +156,18 @@ module.exports = function(RED) {
node.client.on("connect", function() {
node.status({fill:"green",shape:"dot",text:"connected"});
node.serverConfig.connected = true;
});
node.client.on("reconnecting", function() {
node.status({fill:"red",shape:"ring",text:"reconnecting"});
node.warn("reconnecting");
node.serverConfig.connected = false;
});
node.client.on("reconnect", function() {
node.status({fill:"green",shape:"dot",text:"connected"});
node.serverConfig.connected = true;
});
node.client.on("error", function(error) {
@ -157,12 +175,14 @@ module.exports = function(RED) {
node.warn(error);
});
// Connect to server if needed
node.status({fill:"grey",shape:"ring",text:"connecting"});
node.client.connect(function(sessionId) {
}, function(error) {
node.status({fill:"grey",shape:"dot",text:"error"});
node.warn(error);
});
if(!node.serverConfig.connected) {
node.client.connect(function(sessionId) {}, function(error) {
node.status({fill:"grey",shape:"dot",text:"error"});
node.warn(error);
});
}
node.on("input", function(msg) {
node.client.publish(node.topic || msg.topic, msg.payload, msg.headers);
@ -210,15 +230,18 @@ module.exports = function(RED) {
node.client.on("connect", function() {
node.status({fill:"green",shape:"dot",text:"connected"});
node.serverConfig.connected = true;
});
node.client.on("reconnecting", function() {
node.status({fill:"red",shape:"ring",text:"reconnecting"});
node.warn("reconnecting");
node.serverConfig.connected = false;
});
node.client.on("reconnect", function() {
node.status({fill:"green",shape:"dot",text:"connected"});
node.serverConfig.connected = true;
});
node.client.on("error", function(error) {
@ -226,12 +249,14 @@ module.exports = function(RED) {
node.warn(error);
});
// Connect to server if needed
node.status({fill:"grey",shape:"ring",text:"connecting"});
node.client.connect(function(sessionId) {
}, function(error) {
node.status({fill:"grey",shape:"dot",text:"error"});
node.warn(error);
});
if(!node.serverConfig.connected) {
node.client.connect(function(sessionId) {}, function(error) {
node.status({fill:"grey",shape:"dot",text:"error"});
node.warn(error);
});
}
node.on("input", function(msg) {
node.client.ack(msg.messageId, msg.subsriptionId, msg.transaction);