Default the new MQTT 'AutoReconnect' to false

sparkybots · Feb 17, 2016 · 920c384 · 920c384
1 parent ac39cfb
commit 920c384
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/platforms/mqtt/mqtt_adaptor.go b/platforms/mqtt/mqtt_adaptor.go
@@ -30,6 +30,7 @@ func (a *MqttAdaptor) Connect() (errs []error) {
 	if token := a.client.Connect(); token.Wait() && token.Error() != nil {
 		errs = append(errs, token.Error())
 	}
+
 	return
 }
 
@@ -71,6 +72,6 @@ func createClientOptions(clientId, raw string) *mqtt.ClientOptions {
 	opts := mqtt.NewClientOptions()
 	opts.AddBroker(raw)
 	opts.SetClientID(clientId)
-
+	opts.AutoReconnect = false
 	return opts
 }