From bf793a54120edd05c26eb4376eaa209408fad85c Mon Sep 17 00:00:00 2001 From: Anish Mukherjee Date: Tue, 28 Feb 2023 09:29:49 +0530 Subject: [PATCH] add mqtts for secure check --- servercfg/serverconf.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/servercfg/serverconf.go b/servercfg/serverconf.go index 1bcd5081..e3fe8764 100644 --- a/servercfg/serverconf.go +++ b/servercfg/serverconf.go @@ -248,7 +248,7 @@ func GetMessageQueueEndpoint() (string, bool) { } else { host += ":1883" // default } - return host, strings.Contains(host, "wss") || strings.Contains(host, "ssl") + return host, strings.Contains(host, "wss") || strings.Contains(host, "ssl") || strings.Contains(host, "mqtts") } // GetBrokerType - returns the type of MQ broker