diff --git a/mqtt_client.go b/mqtt_client.go index 7236b87..0dc0239 100644 --- a/mqtt_client.go +++ b/mqtt_client.go @@ -289,7 +289,6 @@ func main() { log.Fatalf("Failed to connect to MQTT broker: %v", token.Error()) } - // Subscribe to topics for topic, qos := range topics { if token := client.Subscribe(topic, qos, messageHandler); token.Wait() && token.Error() != nil { log.Fatalf("Failed to subscribe to topic '%s': %v", topic, token.Error())