cosmetics

sebleier · Jul 20, 2010 · 58e0c08 · 58e0c08
1 parent f3d832f
commit 58e0c08
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/kombu/messaging.py b/kombu/messaging.py
@@ -64,13 +64,13 @@ def publish(self, message_data, routing_key=None, delivery_mode=None,
                                      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 @@ def consume(self):
                   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):