frodovdr/node-red
1
0
Fork 0
mirror of https://github.com/node-red/node-red.git synced 2023-10-10 13:36:53 +02:00
Code Issues Releases Wiki Activity

Add Force parameter mqtt client.end() when called in disconnect

Browse Source
This commit is contained in:
Phil Day 2022-05-05 16:12:28 +01:00 committed by Steve-Mcl
parent ca204dea2d
commit 3be75fa822
1 changed files with 17 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
packages/node_modules/@node-red/nodes/core/network/10-mqtt.js vendored
View File

@ -765,11 +765,23 @@ module.exports = function(RED) {
} }
callback && typeof callback == "function" && callback(); callback && typeof callback == "function" && callback();
}; };
if(node.closing) { if(!node.client) { return _callback(); }
return _callback(false, force); if(node.closing) { return _callback(); }
}
var endCallBack = function endCallBack() { let waitEnd = (client, ms) => {
return new Promise( (resolve, reject) => {
node.closing = true;
if(!client) {
resolve();
} else {
const t = setTimeout(reject, ms);
client.end(true, () => {
clearTimeout(t);
resolve()
});
} }
});
};
if(node.connected && node.closeMessage) { if(node.connected && node.closeMessage) {
node.publish(node.closeMessage, function (err) { node.publish(node.closeMessage, function (err) {
node.client.end(endCallBack); node.client.end(endCallBack);