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

Compare commits

base: mahdium:27f0d7ab06b30da26635252401b63b7379e96162
Branches Tags
mahdium:main
...
compare: mahdium:637456213773f61803796e8e2594e90fdb89a4a7
Branches Tags
mahdium:main

2 Commits
27f0d7ab06 ... 6374562137

Author SHA1 Message Date
Mohammad Mahdi
6374562137 Improved logging 2025-09-29 16:37:15 +03:30
Mohammad Mahdi
edb18eebe0 Fix not re-subscribing to topics on reconnect 2025-09-29 16:36:54 +03:30
1 changed files with 2 additions and 0 deletions
Expand all files Collapse all files

2
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:
@@ -49,6 +50,7 @@ func NewClient(logger *zap.Logger, config *config.Config, csvHelper *csv.Helper)
} }
func StartListening(logger *zap.Logger, config *config.Config, client mqtt.Client) { func StartListening(logger *zap.Logger, config *config.Config, client mqtt.Client) {
logger.Info("Subscribing to", zap.Int("topics", len(config.Topics)))
for _, topic := range config.Topics { for _, topic := range config.Topics {
if token := client.Subscribe(topic, 0, nil); token.Wait() && token.Error() != nil { if token := client.Subscribe(topic, 0, nil); token.Wait() && token.Error() != nil {
logger.Error("error subscribing to topic", zap.String("topic", topic), zap.Error(token.Error())) logger.Error("error subscribing to topic", zap.String("topic", topic), zap.Error(token.Error()))