diff --git a/monitor/mqtt_monitor.go b/monitor/mqtt_monitor.go index d4c4bb7..4648be3 100644 --- a/monitor/mqtt_monitor.go +++ b/monitor/mqtt_monitor.go @@ -187,6 +187,7 @@ func (mms *MqttMonitor) MonitorActiveParticipants() { clientMutex.Lock() if localMqttClient != nil { log.Println("[app] [Monitor] client is still working") + clientMutex.Unlock() return } localMqttClient = mms.lazyLoadMonitorMQTTClient()