Set _consuming to True after consume

2010-10-05 23:09:54 +03:00 · 2010-10-05 23:09:54 +03:00 · 1e0f46a5e4
parent 0e35cec74f
commit 1e0f46a5e4
1 changed files with 1 additions and 1 deletions
--- a/kombu/messaging.py
+++ b/kombu/messaging.py
@ -248,7 +248,7 @@ class Consumer(object):
                    self._receive_callback,
                    no_ack=no_ack,
                    nowait=False)
-            self._consuming = False
+            self._consuming = True

    def receive(self, body, message):
        """Method called when a message is received.