mahdium/MQTTLogger
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Fix not re-subscribing to topics on reconnect

Browse Source
This commit is contained in:
Mohammad Mahdi
2025-09-29 16:35:02 +03:30
parent 749ffae0c4
commit 27f0d7ab06
1 changed files with 1 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
internal/mqtt/mqtt.go
View File

@@ -22,6 +22,7 @@ func NewClient(logger *zap.Logger, config *config.Config, csvHelper *csv.Helper)
switch n := notification.(type) { switch n := notification.(type) {
case mqtt.ConnectionNotificationConnected: case mqtt.ConnectionNotificationConnected:
logger.Info("Connected to MQTT broker") logger.Info("Connected to MQTT broker")
StartListening(logger, config, client)
case mqtt.ConnectionNotificationConnecting: case mqtt.ConnectionNotificationConnecting:
logger.Info("connecting", zap.Bool("isReconnect", n.IsReconnect), zap.Int("attempt", n.Attempt)) logger.Info("connecting", zap.Bool("isReconnect", n.IsReconnect), zap.Int("attempt", n.Attempt))
case mqtt.ConnectionNotificationFailed: case mqtt.ConnectionNotificationFailed: