Consumer.consume did not set no_ack setting

2010-10-21 11:04:25 +02:00 · 2010-10-21 11:04:25 +02:00 · d8da3c3dfc
parent b8e61373bd
commit d8da3c3dfc
1 changed files with 1 additions and 0 deletions
--- a/kombu/messaging.py
+++ b/kombu/messaging.py
@ -234,6 +234,7 @@ class Consumer(object):
        if queue.name not in self._active_tags:
            queue.consume(self._add_tag(queue, consumer_tag),
                          self._receive_callback,
+                          no_ack=no_ack,
                          nowait=nowait)

    def consume(self, no_ack=None):