mirror of
https://github.com/openmv/openmv.git
synced 2025-11-04 14:49:50 +08:00
Merge pull request #2170 from openmv/mqtt_fix
scripts/libraries: Fix MQTT SSL params.
This commit is contained in:
commit
9d573a813f
@ -91,19 +91,11 @@ class MQTTClient:
|
||||
self.sock.close()
|
||||
self.sock = None
|
||||
|
||||
try:
|
||||
self.sock = socket.socket()
|
||||
self.sock.settimeout(timeout)
|
||||
if self.ssl_params is not None:
|
||||
self.sock = ssl.wrap_socket(self.sock, self.ssl_params)
|
||||
self.sock.connect(addr)
|
||||
except Exception:
|
||||
self.sock.close()
|
||||
self.sock = socket.socket()
|
||||
self.sock.settimeout(timeout)
|
||||
self.sock.connect(addr)
|
||||
if self.ssl_params is not None:
|
||||
self.sock = ssl.wrap_socket(self.sock, self.ssl_params)
|
||||
self.sock = ssl.wrap_socket(self.sock, **self.ssl_params)
|
||||
|
||||
premsg = bytearray(b"\x10\0\0\0\0\0")
|
||||
msg = bytearray(b"\x04MQTT\x04\x02\0\0")
|
||||
|
||||
Loading…
Reference in New Issue
Block a user