|
@@ -156,11 +156,12 @@ func SetupMQTT() mqtt.Client {
|
|
|
opts := mqtt.NewClientOptions()
|
|
|
broker := servercfg.GetMessageQueueEndpoint()
|
|
|
opts.AddBroker(broker)
|
|
|
+ client := mqtt.NewClient(opts)
|
|
|
tperiod := time.Now().Add(10 * time.Second)
|
|
|
for {
|
|
|
if token := client.Connect(); token.Wait() && token.Error() != nil {
|
|
|
logger.Log(2, "unable to connect to broker, retrying ...")
|
|
|
- if time.Now().Afer(tperiod) {
|
|
|
+ if time.Now().After(tperiod) {
|
|
|
log.Fatal(0, "could not connect to broker, exiting ...", token.Error())
|
|
|
}
|
|
|
} else {
|