diff --git a/monitor/mqtt_monitor.go b/monitor/mqtt_monitor.go
index 3234b81..7300888 100644
--- a/monitor/mqtt_monitor.go
+++ b/monitor/mqtt_monitor.go
@@ -296,9 +296,7 @@ func (mms *MqttMonitor) onConnectionLost(_ mqtt.Client, err error) {
 	Log("connection lost: " + err.Error())
 	// Handle connection loss here (e.g., reconnect attempts, logging)
 	if !mms.IsTerminated() {
-		mms.lostConnectionMutex.Lock()
-		mms.lostConnection = true
-		mms.lostConnectionMutex.Unlock()
+		mms.setConnectionStatus(true)
 	}
 }