From 7e4c87488d8b8ed8c900aed55dd1a3b257d37edf Mon Sep 17 00:00:00 2001 From: Ask Solem Date: Wed, 27 Oct 2010 09:35:41 +0200 Subject: compat: Fixed typo _CSet -> ConsumerSet --- kombu/compat.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) (limited to 'kombu') diff --git a/kombu/compat.py b/kombu/compat.py index a8dfc6c7..06de52e6 100644 --- a/kombu/compat.py +++ b/kombu/compat.py @@ -203,7 +203,7 @@ class ConsumerSet(messaging.Consumer): for queue_name, queue_options in from_dict.items(): queues.append(entry_to_queue(queue_name, **queue_options)) - super(_CSet, self).__init__(self.backend, queues, **kwargs) + super(ConsumerSet, self).__init__(self.backend, queues, **kwargs) def iterconsume(self, limit=None, no_ack=False): return _iterconsume(self.connection, self, no_ack, limit) -- cgit v1.2.1