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

Use shared client connection

Browse Source
This commit is contained in:
Olivier Verhaegen 2023-04-12 13:27:56 +02:00 committed by GitHub
parent 12704951e3
commit b91aa6a506
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 16 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -16,6 +16,7 @@ module.exports = function(RED) {
this.name = n.name; this.name = n.name;
this.username = this.credentials.user; this.username = this.credentials.user;
this.password = this.credentials.password; this.password = this.credentials.password;
this.clientConnection = null;
} }
RED.nodes.registerType("stomp-server",StompServerNode,{ RED.nodes.registerType("stomp-server",StompServerNode,{
credentials: { credentials: {
@ -57,7 +58,11 @@ module.exports = function(RED) {
var node = this; var node = this;
var msg = {topic:this.topic}; var msg = {topic:this.topic};
node.client = new StompClient(node.stompClientOpts); // Save the client connection to the shared server instance if needed
if (!node.server.clientConnection) {
node.server.clientConnection = new StompClient(node.stompClientOpts);
}
node.client = node.server.clientConnection;
node.client.on("connect", function() { node.client.on("connect", function() {
node.status({fill:"green",shape:"dot",text:"connected"}); node.status({fill:"green",shape:"dot",text:"connected"});
@ -128,7 +133,11 @@ module.exports = function(RED) {
} }
var node = this; var node = this;
node.client = new StompClient(node.stompClientOpts); // Save the client connection to the shared server instance if needed
if (!node.server.clientConnection) {
node.server.clientConnection = new StompClient(node.stompClientOpts);
}
node.client = node.server.clientConnection;
node.client.on("connect", function() { node.client.on("connect", function() {
node.status({fill:"green",shape:"dot",text:"connected"}); node.status({fill:"green",shape:"dot",text:"connected"});
@ -193,7 +202,11 @@ module.exports = function(RED) {
// only start connection etc. when acknowledgements are configured to be send by client // only start connection etc. when acknowledgements are configured to be send by client
if (node.serverConfig.ack) { if (node.serverConfig.ack) {
node.client = new StompClient(node.stompClientOpts); // Save the client connection to the shared server instance if needed
if (!node.server.clientConnection) {
node.server.clientConnection = new StompClient(node.stompClientOpts);
}
node.client = node.server.clientConnection;
node.client.on("connect", function() { node.client.on("connect", function() {
node.status({fill:"green",shape:"dot",text:"connected"}); node.status({fill:"green",shape:"dot",text:"connected"});