mirror
/
amqtt
kopia lustrzana https://github.com/Yakifo/amqtt
1
0
Forkuj 0
Kod Zgłoszenia Packages Projekty Wydania Wiki Aktywność

use brokwer_uri default in client connection

feature/refactor-topic_checking
Florian Ludwig 2021-03-14 21:45:28 +01:00
rodzic 560eed263b
commit b72a389e6c
1 zmienionych plików z 3 dodań i 4 usunięć
Pokaż statystyki Ściągnij plik aktualizacji Ściągnij plik porównania Expand all files Collapse all files

7
hbmqtt/client.py
Wyświetl plik

@ -554,12 +554,11 @@ class MQTTClient:
if cleansession is not None: if cleansession is not None:
broker_conf["cleansession"] = cleansession broker_conf["cleansession"] = cleansession
for key in ["uri"]: if not broker_conf.get("uri"):
if not broker_conf.get(key): raise ClientException("Missing connection parameter 'uri'")
raise ClientException("Missing connection parameter '%s'" % key)
s = Session() s = Session()
s.broker_uri = uri s.broker_uri = broker_conf["uri"]
s.client_id = self.client_id s.client_id = self.client_id
s.cafile = broker_conf["cafile"] s.cafile = broker_conf["cafile"]
s.capath = broker_conf["capath"] s.capath = broker_conf["capath"]