From d8da3c3dfc7d133792b67485100a28cac30cb0af Mon Sep 17 00:00:00 2001 From: Ask Solem Date: Thu, 21 Oct 2010 11:04:25 +0200 Subject: [PATCH] Consumer.consume did not set no_ack setting --- kombu/messaging.py | 1 + 1 file changed, 1 insertion(+) diff --git a/kombu/messaging.py b/kombu/messaging.py index 43362741..1ce7e555 100644 --- 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):