dapr
/
components-contrib
mirror of https://github.com/dapr/components-contrib.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Adding small coalesce on scheme to ensure backward compatibility in both the pubsub and binding mqtt components

This commit is contained in:
Phil Kedy 2021-04-06 17:32:47 -04:00
parent 810ec429a7
commit bc0c4fd72e
2 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
bindings/mqtt/mqtt.go
View File

@ -298,7 +298,7 @@ func (m *MQTT) createClientOptions(uri *url.URL, clientID string) *mqtt.ClientOp
switch scheme {
case "mqtt":
scheme = "tcp"
case "mqtts":
case "mqtts", "tcps":
scheme = "ssl"
}
opts.AddBroker(scheme + "://" + uri.Host)

2
pubsub/mqtt/mqtt.go
View File

@ -291,7 +291,7 @@ func (m *mqttPubSub) createClientOptions(uri *url.URL, clientID string) *mqtt.Cl
switch scheme {
case "mqtt":
scheme = "tcp"
case "mqtts":
case "mqtts", "tcps":
scheme = "ssl"
}
opts.AddBroker(scheme + "://" + uri.Host)