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

cosmetics

This commit is contained in:
Ask Solem 2010-07-20 16:14:38 +02:00
parent f3d832fc3d
commit 58e0c08146
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
kombu/messaging.py
View File

@ -64,13 +64,13 @@ class Producer(object):
immediate)
_next_tag = count(1).next
class Consumer(object):
no_ack = False
auto_declare = True
callbacks = None
on_decode_error = None
_next_tag = count(1).next # global
def __init__(self, channel, bindings, no_ack=None, auto_declare=None,
callbacks=None):
@ -117,7 +117,7 @@ class Consumer(object):
nowait=False)
def _add_tag(self, binding):
tag = self._active_tags[binding] = str(_next_tag())
tag = self._active_tags[binding] = str(self._next_tag())
return tag
def _receive_callback(self, raw_message):