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

Removes deprecated Consumer.add_queue_from_dict

This commit is contained in:
Ask Solem 2015-12-18 14:59:11 -08:00
parent ec18cf8144
commit 4efd57eae9
2 changed files with 1 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
kombu/compat.py
View File

@ -199,7 +199,7 @@ class ConsumerSet(messaging.Consumer):
return self.purge() return self.purge()
def add_consumer_from_dict(self, queue, **options): def add_consumer_from_dict(self, queue, **options):
return self.add_queue_from_dict(queue, **options) return self.add_queue(Queue.from_dict(queue, **options))
def add_consumer(self, consumer): def add_consumer(self, consumer):
for queue in consumer.queues: for queue in consumer.queues:

10
kombu/messaging.py
View File

@ -457,16 +457,6 @@ class Consumer(object):
self._queues[queue.name] = queue self._queues[queue.name] = queue
return queue return queue
def add_queue_from_dict(self, queue, **options):
"""This method is deprecated.
Instead please use::
consumer.add_queue(Queue.from_dict(d))
"""
return self.add_queue(Queue.from_dict(queue, **options))
def consume(self, no_ack=None): def consume(self, no_ack=None):
"""Start consuming messages. """Start consuming messages.