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

Improved error states and logging

Browse Source
This commit is contained in:
Olivier Verhaegen
2023-08-07 09:49:29 +02:00
committed by GitHub
parent 79b93f30ec
commit 5ef67de581
1 changed files with 9 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -54,15 +54,15 @@ module.exports = function(RED) {
}
}
function setStatusError(node, allNodes) {
function setStatusError(node, allNodes, message = undefined) {
if(allNodes) {
for (var id in node.users) {
if (hasProperty(node.users, id)) {
node.users[id].status({ fill: "red", shape: "dot", text: "error" });
node.users[id].status({ fill: "red", shape: "dot", text: message ?? "error" });
}
}
} else {
node.status({ fill: "red", shape: "dot", text: "error" });
node.status({ fill: "red", shape: "dot", text: message ?? "error" });
}
}
@@ -219,22 +219,25 @@ module.exports = function(RED) {
});
node.client.on("reconnecting", function() {
node.warn("reconnecting");
node.warn("Reconnecting to STOMP server");
node.connecting = true;
node.connected = false;
node.log("Reconnecting to STOMP server...", {url: `${node.options.address}:${node.options.port}`, protocolVersion: node.options.protocolVersion});
node.log(`Reconnecting to STOMP server, url: ${node.options.address}:${node.options.port}, protocolVersion: ${node.options.protocolVersion}`);
setStatusConnecting(node, true);
});
node.client.on("error", function(err) {
node.error(err);
setStatusError(node, true);
if (err.reconnectionFailed) {
setStatusError(node, true);
}
});
node.client.connect();
} catch (err) {
node.error(err);
setStatusError(node, true, "Reconnection failed: exceeded number of reconnection attempts");
}
} else {
node.log("Not connecting to STOMP server, already connected");