From c87ff3ca26e09e322fd47876099d76cf0bc382b5 Mon Sep 17 00:00:00 2001
From: Phil Day <69908274+PhilDay-CT@users.noreply.github.com>
Date: Mon, 9 May 2022 16:22:50 +0100
Subject: [PATCH] Update
 packages/node_modules/@node-red/nodes/core/network/10-mqtt.js

Co-authored-by: Stephen McLaughlin <44235289+Steve-Mcl@users.noreply.github.com>
---
 .../node_modules/@node-red/nodes/core/network/10-mqtt.js     | 5 +++++
 1 file changed, 5 insertions(+)

diff --git a/packages/node_modules/@node-red/nodes/core/network/10-mqtt.js b/packages/node_modules/@node-red/nodes/core/network/10-mqtt.js
index 2a0241316..0b89b29cd 100644
--- a/packages/node_modules/@node-red/nodes/core/network/10-mqtt.js
+++ b/packages/node_modules/@node-red/nodes/core/network/10-mqtt.js
@@ -719,6 +719,11 @@ module.exports = function(RED) {
                 setStatusConnecting(node, true);
                 try {
                     node.serverProperties = {};
+                    if(node.client) {
+                        //belt and braces to avoid left over clients
+                        node.client.end(true);
+                        node._clientRemoveListeners();
+                    }
                     node.client = mqtt.connect(node.brokerurl, node.options);
                     node.client.setMaxListeners(0);
                     let callbackDone = false; //prevent re-connects causing node._clientOn('connect' firing callback multiple times