diff --git a/serial_to_mqtt_bridge/serial_to_mqtt.py b/serial_to_mqtt_bridge/serial_to_mqtt.py index 7a839c269683dcc52c91a8d473d802ed9b82d22a..caab6998eef92b203600e779a9e9f7f907aaa63c 100755 --- a/serial_to_mqtt_bridge/serial_to_mqtt.py +++ b/serial_to_mqtt_bridge/serial_to_mqtt.py @@ -102,16 +102,16 @@ def create_mqtt_client(broker_url): """ if broker_url.startswith('mqtt://'): print("Using MQTT protocol...") - return mqtt.Client(mqtt.CallbackAPIVersion.VERSION1) + return mqtt.Client() elif broker_url.startswith('ws://'): print("Using WebSocket protocol without TLS...") - return mqtt.Client(mqtt.CallbackAPIVersion.VERSION1, transport="websockets") + return mqtt.Client(transport="websockets") elif broker_url.startswith('wss://'): print("Using WebSocket protocol with TLS...") - return mqtt.Client(mqtt.CallbackAPIVersion.VERSION1, transport="websockets") + return mqtt.Client(transport="websockets") else: print("No protocol prefix found, using MQTT protocol...") - return mqtt.Client(mqtt.CallbackAPIVersion.VERSION1) + return mqtt.Client() def connect_mqtt(broker, port, username=None, password=None): """ diff --git a/serial_to_mqtt_bridge/susGatewayApp.exe b/serial_to_mqtt_bridge/susGatewayApp.exe index e7d106a64dc7649e37d3ab13425bde7706b95266..1de2fc019e3cdbbba188d6869ca8b6c1ec4d6228 100644 Binary files a/serial_to_mqtt_bridge/susGatewayApp.exe and b/serial_to_mqtt_bridge/susGatewayApp.exe differ