Rooba
/
kombu
mirror of https://github.com/celery/kombu.git
1
1
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fixing up after_reply_message_received with better Exception Handling

This commit is contained in:
Brian Bouterse 2014-03-17 14:01:28 -04:00
parent 383f9510b5
commit d79a5ff069
1 changed files with 1 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
kombu/transport/qpid.py
View File

@ -750,12 +750,8 @@ class Channel(base.StdChannel):
""" """
self._broker.delExchange(exchange_name) self._broker.delExchange(exchange_name)
@ProtonExceptionHandler('queue in use')
def after_reply_message_received(self, queue): def after_reply_message_received(self, queue):
#TODO investigate the correct behavior of this message. It should
# not just return. This is related to the event broadcast behavior
# of celery control().
#TODO write docstring
return
self._delete(queue) self._delete(queue)
def queue_bind(self, queue, exchange, routing_key, **kwargs): def queue_bind(self, queue, exchange, routing_key, **kwargs):