We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 52ea7ca commit c00156eCopy full SHA for c00156e
msgflo/msgflo.py
@@ -255,7 +255,9 @@ def __init__(self, broker):
255
if self.broker_info.scheme == 'mqtts':
256
default_port = 8883
257
ca_certs = params.get('ca_certs')
258
- self._client.tls_set(ca_certs=ca_certs)
+ certfile = params.get('certfile')
259
+ keyfile = params.get('keyfile')
260
+ self._client.tls_set(ca_certs=ca_certs, certfile=certfile, keyfile=keyfile)
261
if self.broker_info.username:
262
self._client.username_pw_set(self.broker_info.username, self.broker_info.password)
263
0 commit comments