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

Improved logging

Browse Source
This commit is contained in:
Mohammad Mahdi
2025-09-29 16:37:15 +03:30
parent edb18eebe0
commit 6374562137
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

@@ -50,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()))