From a0f7e92e40c41228f8af4814bdf277b789098a89 Mon Sep 17 00:00:00 2001
From: Phil Day <phil.day@configuredthings.com>
Date: Mon, 9 May 2022 16:29:39 +0100
Subject: [PATCH] call client.end with force=true on timeout

---
 .../node_modules/@node-red/nodes/core/network/10-mqtt.js  | 8 ++++++--
 1 file changed, 6 insertions(+), 2 deletions(-)

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 0b89b29cd..3b2a17cdd 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
@@ -842,8 +842,12 @@ module.exports = function(RED) {
                     if(!client) { 
                         resolve();
                      } else {
-                         const t = setTimeout(reject, ms);
-                         client.end(() => {
+                        const t = setTimeout(() => {
+                            //clean end() has exceeded WAIT_END, lets force end!
+                            client && client.end(true);
+                            reject();
+                        }, ms);
+                        client.end(() => {
                              clearTimeout(t);
                              resolve()
                          });