rabbit: remove unused code

We never cancel queues...

Change-Id: Ib83c00971da11b364e7ef19e60c472eaa4e654eb
This commit is contained in:
Mehdi Abaakouk 2015-04-30 17:47:44 +02:00
parent cca84f66d4
commit 2d81577fa1

@ -251,16 +251,6 @@ class ConsumerBase(object):
self.queue.consume(*args, callback=_callback, **options)
def cancel(self):
"""Cancel the consuming from the queue, if it has started."""
try:
self.queue.cancel(self.tag)
except KeyError as e:
# NOTE(comstud): Kludge to get around a amqplib bug
if six.text_type(e) != "u'%s'" % self.tag:
raise
self.queue = None
class DirectConsumer(ConsumerBase):
"""Queue/consumer class for 'direct'."""