This commit is contained in:
4
main.go
4
main.go
@@ -115,9 +115,7 @@ func setupMQTT() *mqtt.ClientOptions {
|
|||||||
opts := MQTT.NewClientOptions()
|
opts := MQTT.NewClientOptions()
|
||||||
opts.AddBroker(fmt.Sprintf("tcp://%s:%s", os.Getenv("MQTTBROKER"), os.Getenv("MQTTPORT")))
|
opts.AddBroker(fmt.Sprintf("tcp://%s:%s", os.Getenv("MQTTBROKER"), os.Getenv("MQTTPORT")))
|
||||||
opts.SetUsername(os.Getenv("MQTTUSER"))
|
opts.SetUsername(os.Getenv("MQTTUSER"))
|
||||||
opts.SetPassword(os.Getenv("MQTTPASS"))
|
opts.SetPassword(os.Getenv("MQTTPASSWORD"))
|
||||||
log.Println(os.Getenv("MQTTPASS"))
|
|
||||||
log.Println(os.Getenv("MQTTUSER"))
|
|
||||||
opts.SetClientID("rgbboard")
|
opts.SetClientID("rgbboard")
|
||||||
|
|
||||||
return opts
|
return opts
|
||||||
|
|||||||
Reference in New Issue
Block a user