From 0e35cec74fc085edf8b352dbf46760ac436cb0b2 Mon Sep 17 00:00:00 2001 From: David Gelvin Date: Tue, 5 Oct 2010 20:13:57 +0300 Subject: [PATCH] Include requeue=False when rejecting a message --- kombu/transport/base.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/kombu/transport/base.py b/kombu/transport/base.py index 685a71a5..23033394 100644 --- a/kombu/transport/base.py +++ b/kombu/transport/base.py @@ -74,7 +74,7 @@ class Message(object): if self.acknowledged: raise self.MessageStateError( "Message already acknowledged with state: %s" % self._state) - self.channel.basic_reject(self.delivery_tag) + self.channel.basic_reject(self.delivery_tag, requeue=False) self._state = "REJECTED" def requeue(self):