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 1 additions and 0 deletions
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) {
logger.Info("Subscribing to", zap.Int("topics", len(config.Topics)))
for _, topic := range config.Topics {
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()))