# HG changeset patch # User Edouard Tisserant <edouard@beremiz.fr> # Date 1737542367 -3600 # Node ID c6c80c08849718bd5e85f88df51ebd59bb580a9b # Parent 97e93962be0c9db07fef2769a3925d8f8d5e3950 MQTT: fix typo in resub python callback. diff -r 97e93962be0c -r c6c80c088497 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