From a13b5bb8e6cd05ba2996f9b3f9e9e2e90dd1b58d Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?J=C3=BCrgen=20Eckel?= Date: Tue, 5 Mar 2024 14:21:18 +0100 Subject: [PATCH] fixed mqtt URI bug MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Signed-off-by: Jürgen Eckel --- util/mqtt.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/util/mqtt.go b/util/mqtt.go index 6b27963..3de4bc5 100644 --- a/util/mqtt.go +++ b/util/mqtt.go @@ -39,7 +39,7 @@ func lazyLoadMQTTClient() { conf := config.GetConfig() hostPort := net.JoinHostPort(conf.MqttDomain, strconv.FormatInt(int64(conf.MqttPort), 10)) - uri := "tcp://%s" + hostPort + uri := "tcp://" + hostPort opts := mqtt.NewClientOptions().AddBroker(uri) opts.SetClientID(conf.ValidatorAddress)