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 f8689ef9a..5e64677e9 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
@@ -837,7 +837,7 @@ module.exports = function(RED) {
                         resolve();
                      } else {
                          const t = setTimeout(reject, ms);
-                         client.end(() => {
+                         client.end(true, () => {
                              clearTimeout(t);
                              resolve()
                          });