Fix not re-subscribing to topics on reconnect

2025-09-29 16:35:02 +03:30
parent 749ffae0c4
commit edb18eebe0
1 changed files with 1 additions and 0 deletions
--- a/internal/mqtt/mqtt.go
+++ b/internal/mqtt/mqtt.go
@@ -22,6 +22,7 @@ func NewClient(logger *zap.Logger, config *config.Config, csvHelper *csv.Helper)
 		switch n := notification.(type) {
 		case mqtt.ConnectionNotificationConnected:
 			logger.Info("Connected to MQTT broker")
+			StartListening(logger, config, client)
 		case mqtt.ConnectionNotificationConnecting:
 			logger.Info("connecting", zap.Bool("isReconnect", n.IsReconnect), zap.Int("attempt", n.Attempt))
 		case mqtt.ConnectionNotificationFailed: