File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -295,11 +295,14 @@ class MqttMonitorType extends MonitorType {
295295 settle ( ( ) => reject ( error ) ) ;
296296 } ;
297297
298- const timeoutID = setTimeout ( ( ) => {
299- log . debug ( this . name , "MQTT timeout triggered" ) ;
300- // Keep the connection alive — just stop waiting for this check cycle
301- settle ( ( ) => reject ( new Error ( "Timeout, Message not received" ) ) ) ;
302- } , interval * 1000 * 0.8 ) ;
298+ const timeoutID = setTimeout (
299+ ( ) => {
300+ log . debug ( this . name , "MQTT timeout triggered" ) ;
301+ // Keep the connection alive — just stop waiting for this check cycle
302+ settle ( ( ) => reject ( new Error ( "Timeout, Message not received" ) ) ) ;
303+ } ,
304+ interval * 1000 * 0.8
305+ ) ;
303306
304307 // Subscribe to this topic if not already subscribed on this connection.
305308 // Attach the message listener only after the subscribe callback fires so that
You can’t perform that action at this time.
0 commit comments