From 777efa904c120d31db7af1cb966cd53dcc92f1e0 Mon Sep 17 00:00:00 2001 From: Roman Livshits Date: Wed, 29 May 2024 09:31:32 +0300 Subject: [PATCH] Migrate to paho-mqtt 2 * addressing breaking change documented on https://github.com/eclipse/paho.mqtt.python/blob/master/docs/migrations.rst#versioned-the-user-callbacks --- src/MQTTLibrary/MQTTKeywords.py | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/src/MQTTLibrary/MQTTKeywords.py b/src/MQTTLibrary/MQTTKeywords.py index 63934b5..9b2ec3a 100644 --- a/src/MQTTLibrary/MQTTKeywords.py +++ b/src/MQTTLibrary/MQTTKeywords.py @@ -68,7 +68,9 @@ def connect(self, broker, port=1883, client_id="", clean_session=True): logger.info('Connecting to %s at port %s' % (broker, port)) self._connected = False self._unexpected_disconnect = False - self._mqttc = mqtt.Client(client_id, clean_session) + self._mqttc = mqtt.Client( + mqtt.CallbackAPIVersion.VERSION1, client_id, clean_session + ) # set callbacks self._mqttc.on_connect = self._on_connect