diff --git a/go/l17.go b/go/l17.go index db3c22d..a9e8286 100644 --- a/go/l17.go +++ b/go/l17.go @@ -54,11 +54,15 @@ func main() { broker := os.Getenv("broker_mqtt") ClientID := os.Getenv("clientid_mqtt") topic := os.Getenv("topic_mqtt") + username := os.Getenv("login_mqtt") + password := os.Getenv("password_mqtt") opts := mqtt.NewClientOptions() opts.AddBroker(broker) opts.SetClientID(ClientID) opts.SetConnectTimeout(5 * time.Second) + opts.SetUsername(username) + opts.SetPassword(password) client := mqtt.NewClient(opts) if token := client.Connect(); token.Wait() && token.Error() != nil { log.Fatalf("%v\n", token.Error()) } @@ -68,11 +72,13 @@ func main() { city, temp := WeatherReq() payload := fmt.Sprintf("City: %s, Temperature: %.2f°C", city, temp) - token := client.Publish(topic, 0, false, payload) + token := client.Publish(topic, 1, false, payload) + ticket := time.NewTicker(2 * time.Second) + defer ticket.Stop() token.Wait() if err = token.Error(); err != nil { log.Fatalf("%v\n", token.Error) } else { fmt.Println("Sent in", topic) } -} \ No newline at end of file +} diff --git a/go/output/l17 b/go/output/l17 index 5323cf7..8326db4 100755 Binary files a/go/output/l17 and b/go/output/l17 differ