beremiz

MQTT: fix typo in resub python callback.

17 months ago, Edouard Tisserant
c6c80c088497
Parents 97e93962be0c
Children 59f90953b117
MQTT: fix typo in resub python callback.
1 files changed, 3 insertions(+), 3 deletions(-)
  • +3 -3
    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