From d79a5ff06929b6ff27ebadcb55e8ae71eb75dc60 Mon Sep 17 00:00:00 2001
From: Brian Bouterse <bmbouter@gmail.com>
Date: Mon, 17 Mar 2014 14:01:28 -0400
Subject: [PATCH] Fixing up after_reply_message_received with better Exception
 Handling

---
 kombu/transport/qpid.py | 6 +-----
 1 file changed, 1 insertion(+), 5 deletions(-)

diff --git a/kombu/transport/qpid.py b/kombu/transport/qpid.py
index 8c987b7e..589c38b3 100644
--- a/kombu/transport/qpid.py
+++ b/kombu/transport/qpid.py
@@ -750,12 +750,8 @@ class Channel(base.StdChannel):
         """
         self._broker.delExchange(exchange_name)
 
+    @ProtonExceptionHandler('queue in use')
     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)
 
     def queue_bind(self, queue, exchange, routing_key, **kwargs):