diff options
| author | Ask Solem <askh@opera.com> | 2010-10-27 09:35:41 +0200 |
|---|---|---|
| committer | Ask Solem <askh@opera.com> | 2010-10-27 09:35:41 +0200 |
| commit | 7e4c87488d8b8ed8c900aed55dd1a3b257d37edf (patch) | |
| tree | 01c5c767441c9601b65e2729562646e7637286f6 /kombu | |
| parent | 8a49a85b8ea8aa19d1255693142dda3c21aa09cc (diff) | |
| download | kombu-7e4c87488d8b8ed8c900aed55dd1a3b257d37edf.tar.gz | |
compat: Fixed typo _CSet -> ConsumerSet
Diffstat (limited to 'kombu')
| -rw-r--r-- | kombu/compat.py | 2 |
1 files changed, 1 insertions, 1 deletions
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) |