From 2d81577fa1eeb077767c39779e5fa7483986fdf5 Mon Sep 17 00:00:00 2001
From: Mehdi Abaakouk <mehdi.abaakouk@enovance.com>
Date: Thu, 30 Apr 2015 17:47:44 +0200
Subject: [PATCH] rabbit: remove unused code
We never cancel queues...
Change-Id: Ib83c00971da11b364e7ef19e60c472eaa4e654eb
---
oslo_messaging/_drivers/impl_rabbit.py | 10 ----------
1 file changed, 10 deletions(-)
diff --git a/oslo_messaging/_drivers/impl_rabbit.py b/oslo_messaging/_drivers/impl_rabbit.py
index 4b977eb00..5dfe3ab1e 100644
--- a/oslo_messaging/_drivers/impl_rabbit.py
+++ b/oslo_messaging/_drivers/impl_rabbit.py
@@ -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'."""