diff --git a/monitor/mqtt_monitor.go b/monitor/mqtt_monitor.go
index 39d8310..d4c4bb7 100644
--- a/monitor/mqtt_monitor.go
+++ b/monitor/mqtt_monitor.go
@@ -217,6 +217,7 @@ func (mms *MqttMonitor) MonitorActiveParticipants() {
 				log.Println("[app] [Monitor] retry establishing a connection")
 				break // Exit inner loop on disconnect
 			}
+			mms.SetMaxRetries()
 			time.Sleep(60 * time.Second) // Adjust sleep time based on your needs
 		}
 	}