From 2182c1a4f73dab8783106c6a87b88867350e9780 Mon Sep 17 00:00:00 2001 From: Takeshi Watanabe Date: Tue, 27 Mar 2018 08:45:21 +0900 Subject: [PATCH] Use paho configuration API instead of setting it directly with struct initializer. (#5707) --- pkg/event/target/mqtt.go | 19 +++++++++---------- 1 file changed, 9 insertions(+), 10 deletions(-) diff --git a/pkg/event/target/mqtt.go b/pkg/event/target/mqtt.go index 8acf1c0c5..34b285161 100644 --- a/pkg/event/target/mqtt.go +++ b/pkg/event/target/mqtt.go @@ -92,16 +92,15 @@ func (target *MQTTTarget) Close() error { // NewMQTTTarget - creates new MQTT target. func NewMQTTTarget(id string, args MQTTArgs) (*MQTTTarget, error) { - options := &mqtt.ClientOptions{ - ClientID: args.ClientID, - CleanSession: true, - Username: args.User, - Password: args.Password, - MaxReconnectInterval: args.MaxReconnectInterval, - KeepAlive: args.KeepAlive, - TLSConfig: tls.Config{RootCAs: args.RootCAs}, - } - options.AddBroker(args.Broker.String()) + options := mqtt.NewClientOptions(). + SetClientID(args.ClientID). + SetCleanSession(true). + SetUsername(args.User). + SetPassword(args.Password). + SetMaxReconnectInterval(args.MaxReconnectInterval). + SetKeepAlive(args.KeepAlive). + SetTLSConfig(&tls.Config{RootCAs: args.RootCAs}). + AddBroker(args.Broker.String()) client := mqtt.NewClient(options) token := client.Connect()