Rooba
/
kombu
mirror of https://github.com/celery/kombu.git
1
1
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Merge branch 'dgelvin/master' 

Conflicts:
	kombu/messaging.py
This commit is contained in:
Ask Solem 2010-10-06 09:14:49 +02:00
parent 801c108b43 1e0f46a5e4
commit 36dd024386
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
kombu/transport/base.py
View File

@ -74,7 +74,7 @@ class Message(object):
if self.acknowledged: if self.acknowledged:
raise self.MessageStateError( raise self.MessageStateError(
"Message already acknowledged with state: %s" % self._state) "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" self._state = "REJECTED"
def requeue(self): def requeue(self):