poc/mqtt
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

checking git commits

Browse Source
This commit is contained in:
jothi
2025-07-31 07:55:32 +00:00
parent 02fe9ea45e
commit 5aad1d7d44
1 changed files with 0 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
mqtt_client.go
View File

@@ -289,7 +289,6 @@ func main() {
log.Fatalf("Failed to connect to MQTT broker: %v", token.Error()) log.Fatalf("Failed to connect to MQTT broker: %v", token.Error())
} }
// Subscribe to topics
for topic, qos := range topics { for topic, qos := range topics {
if token := client.Subscribe(topic, qos, messageHandler); token.Wait() && token.Error() != nil { if token := client.Subscribe(topic, qos, messageHandler); token.Wait() && token.Error() != nil {
log.Fatalf("Failed to subscribe to topic '%s': %v", topic, token.Error()) log.Fatalf("Failed to subscribe to topic '%s': %v", topic, token.Error())