From 0c52d6b8be40608e51612da47fca2e465e273042 Mon Sep 17 00:00:00 2001 From: Olivier Verhaegen <56387556+OlivierVerhaegen@users.noreply.github.com> Date: Wed, 12 Apr 2023 13:50:39 +0200 Subject: [PATCH] Bugfix shared connection --- io/stomp/18-stomp.js | 18 +++++++++--------- 1 file changed, 9 insertions(+), 9 deletions(-) diff --git a/io/stomp/18-stomp.js b/io/stomp/18-stomp.js index 067cb4bf..1a2b2c12 100644 --- a/io/stomp/18-stomp.js +++ b/io/stomp/18-stomp.js @@ -59,10 +59,10 @@ module.exports = function(RED) { var node = this; var msg = {topic:this.topic}; // Save the client connection to the shared server instance if needed - if (!node.server.clientConnection) { - node.server.clientConnection = new StompClient(node.stompClientOpts); + if (!node.serverConfig.clientConnection) { + node.serverConfig.clientConnection = new StompClient(node.stompClientOpts); } - node.client = node.server.clientConnection; + node.client = node.serverConfig.clientConnection; node.client.on("connect", function() { node.status({fill:"green",shape:"dot",text:"connected"}); @@ -134,10 +134,10 @@ module.exports = function(RED) { var node = this; // Save the client connection to the shared server instance if needed - if (!node.server.clientConnection) { - node.server.clientConnection = new StompClient(node.stompClientOpts); + if (!node.serverConfig.clientConnection) { + node.serverConfig.clientConnection = new StompClient(node.stompClientOpts); } - node.client = node.server.clientConnection; + node.client = node.serverConfig.clientConnection; node.client.on("connect", function() { node.status({fill:"green",shape:"dot",text:"connected"}); @@ -203,10 +203,10 @@ module.exports = function(RED) { // only start connection etc. when acknowledgements are configured to be send by client if (node.serverConfig.ack) { // Save the client connection to the shared server instance if needed - if (!node.server.clientConnection) { - node.server.clientConnection = new StompClient(node.stompClientOpts); + if (!node.serverConfig.clientConnection) { + node.serverConfig.clientConnection = new StompClient(node.stompClientOpts); } - node.client = node.server.clientConnection; + node.client = node.serverConfig.clientConnection; node.client.on("connect", function() { node.status({fill:"green",shape:"dot",text:"connected"});