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):