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):