MQTT: fix typo in resub python callback.
authorEdouard Tisserant <edouard@beremiz.fr>
Wed, 22 Jan 2025 11:39:27 +0100 (8 weeks ago)
changeset 4100 c6c80c088497
parent 4099 97e93962be0c
child 4101 59f90953b117
MQTT: fix typo in resub python callback.
mqtt/library.py
--- a/mqtt/library.py	Tue Jan 21 16:28:43 2025 +0100
+++ b/mqtt/library.py	Wed Jan 22 11:39:27 2025 +0100
@@ -38,16 +38,16 @@
 # - one callback registered to C side per client
 MQTT_client_cbs = {}
 
-def mqtt_per_client_cb_factory(client):
+def mqtt_per_client_cb_factory(clientname):
     def per_client_onmsg_cb(topic, dataptr, datalen):
         payload = ctypes.string_at(dataptr, datalen)
-        subscriber,_Qos = MQTT_subscribers_cbs[client].get(topic, None)
+        subscriber,_Qos = MQTT_subscribers_cbs[clientname].get(topic, None)
         if subscriber:
             subscriber(topic, payload)
             return 0
         return 1
     def per_client_resub_cb():
-        for topic,(_cb,Qos) in MQTT_subscribers_cbs[client].items():
+        for topic,(_cb,QoS) in MQTT_subscribers_cbs[clientname].items():
             _MQTT_subscribe(clientname, topic, QoS)
         return 1
     return per_client_onmsg_cb,per_client_resub_cb