hbmqtt "'NoneType' object has no attribute 'delivered_message

"'NoneType' object has no attribute 'delivered_message_queue'" when losing connection

Open hongquan opened this issue 7 years ago • 3 comments

Steps to reproduce

Run a script which use hbmqtt, connecting to Mosquitto broker.
Restart the broker, to cause a temporary disconnection.

What happened:

hbmqtt failed:

2018-02-01 14:22:46 INFO:__main__: MQTT payload from daothanh/r2/ds/02: bytearray(b'1')
Disconnected from broker
Traceback (most recent call last):
  File "/usr/lib/python3.6/runpy.py", line 193, in _run_module_as_main
    "__main__", mod_spec)
  File "/usr/lib/python3.6/runpy.py", line 85, in _run_code
    exec(code, run_globals)
  File "/home/quan/Works/AgriConnect/PlantingHouse/controlview/collector/__main__.py", line 228, in <module>
    loop.run_until_complete(asyncio.gather(*coroutines))
  File "uvloop/loop.pyx", line 1364, in uvloop.loop.Loop.run_until_complete
  File "/home/quan/Works/AgriConnect/PlantingHouse/controlview/collector/__main__.py", line 199, in collect_mqtt
    message = await mqtt_client.deliver_message(MQTT_TIMEOUT)
  File "/home/quan/Works/Envs/agri/lib/python3.6/site-packages/hbmqtt/client.py", line 335, in deliver_message
    return deliver_task.result()
  File "/home/quan/Works/Envs/agri/lib/python3.6/site-packages/hbmqtt/mqtt/protocol/handler.py", line 466, in mqtt_deliver_next_message
    message = yield from self.session.delivered_message_queue.get()
AttributeError: 'NoneType' object has no attribute 'delivered_message_queue'