diff --git a/kombu/compat.py b/kombu/compat.py index 7347e9bc..e86ac0f5 100644 --- a/kombu/compat.py +++ b/kombu/compat.py @@ -199,7 +199,7 @@ class ConsumerSet(messaging.Consumer): return self.purge() 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): for queue in consumer.queues: diff --git a/kombu/messaging.py b/kombu/messaging.py index 64529c09..0e3155d3 100644 --- a/kombu/messaging.py +++ b/kombu/messaging.py @@ -457,16 +457,6 @@ class Consumer(object): self._queues[queue.name] = 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): """Start consuming messages.