add mqtts for secure check

This commit is contained in:
Anish Mukherjee 2023-02-28 09:29:49 +05:30
parent c57c892119
commit bf793a5412

View file

@ -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