search

gmr / rabbitpy

A pure python, thread-safe, minimalistic and pythonic RabbitMQ client library
http://rabbitpy.readthedocs.org
BSD 3-Clause "New" or "Revised" License
242 stars 58 forks source link

Traceback after calling _interrupt_wait_on_frame #109

Open the-allanc opened 7 years ago

the-allanc commented 7 years ago

I know that _interrupt_wait_on_frame is an internal method, but I'm invoking it on a channel object to try and get rabbitpy to return from a Queue.get invocation (see my comments regarding #108).

After doing it, rabbitpy generates this exception:

  File "/home/allanc/env35/lib/python3.5/site-packages/rabbitpy/amqp_queue.py", line 287, in get
    return self.channel._get_message()  # pylint: disable=protected-access
  File "/home/allanc/env35/lib/python3.5/site-packages/rabbitpy/channel.py", line 375, in _get_message
    return self._wait_for_content_frames(frame_value)
  File "/home/allanc/env35/lib/python3.5/site-packages/rabbitpy/channel.py", line 467, in _wait_for_content_frames
    method_frame.name, method_frame.delivery_tag)
AttributeError: 'NoneType' object has no attribute 'name'