added timeout for removing the dead loop state

This commit is contained in:
Tarun Singh 2022-01-20 13:04:59 -05:00
parent 227bbdea2f
commit 22256dfcd2
2 changed files with 5 additions and 2 deletions

View File

@ -359,9 +359,11 @@ class Monitor extends BeanModel {
}); });
bean.status = UP; bean.status = UP;
} catch (error) { } catch (error) {
if (error.message !== "Timeout") {
bean.status = DOWN; bean.status = DOWN;
bean.msg = error.message; bean.msg = error.message;
} }
}
} else { } else {
bean.msg = "Unknown Monitor Type"; bean.msg = "Unknown Monitor Type";
bean.status = PENDING; bean.status = PENDING;

View File

@ -131,6 +131,7 @@ exports.mqttAsync = function (hostname, topic, okMessage, options = {}) {
setTimeout(() => { setTimeout(() => {
client.end(); client.end();
reject("Timeout");
}, interval * 1000); }, interval * 1000);
}); });