Reticulum/SebastianObi-LXMF-Tools
1
0
Fork 0
mirror of https://github.com/SebastianObi/LXMF-Tools.git synced 2025-12-22 10:27:12 +00:00
Code Issues Packages Projects Releases Wiki Activity

lxmf_bridge_mqtt: Updated paho-mqtt library

Browse Source
This commit is contained in:
SebastianObi
2025-03-19 19:53:00 +01:00
parent 2558352b42
commit 1be6b9e0ac
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
lxmf_bridge_mqtt/lxmf_bridge_mqtt.py
View File

@@ -912,7 +912,7 @@ def mqtt_state_now():
#### MQTT - Connected ####
def mqtt_connected_callback(client, userdata, flags, rc):
def mqtt_connected_callback(client, userdata, flags, reason_code, properties):
MQTT_CONNECTION.subscribe(CONFIG["mqtt"]["topic_power"])
MQTT_CONNECTION.subscribe(CONFIG["mqtt"]["topic_state"])
MQTT_CONNECTION.subscribe(CONFIG["mqtt"]["topic_send"])
@@ -1451,7 +1451,7 @@ def setup(path=None, path_rns=None, path_log=None, loglevel=None, service=False,
log("...............................................................................", LOG_FORCE)
log("MQTT - Connecting ...", LOG_DEBUG)
MQTT_CONNECTION = mqtt.Client(CONFIG["mqtt"]["client_id"], False, userdata=None, transport=CONFIG["mqtt"]["transport"])
MQTT_CONNECTION = mqtt.Client(mqtt.CallbackAPIVersion.VERSION2, client_id=CONFIG["mqtt"]["client_id"], clean_session=False, userdata=None, transport=CONFIG["mqtt"]["transport"])
MQTT_CONNECTION.on_connect = mqtt_connected_callback
MQTT_CONNECTION.message_callback_add(CONFIG["mqtt"]["topic_power"], mqtt_message_received_callback_power)
MQTT_CONNECTION.message_callback_add(CONFIG["mqtt"]["topic_state"], mqtt_message_received_callback_state)