You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by gs...@apache.org on 2011/04/28 18:39:37 UTC
svn commit: r1097539 - /qpid/trunk/qpid/python/qpid/messaging/endpoints.py
Author: gsim
Date: Thu Apr 28 16:39:36 2011
New Revision: 1097539
URL: http://svn.apache.org/viewvc?rev=1097539&view=rev
Log:
QPID-3232: Call _grant() & wakeup() after returned message has been counted
Modified:
qpid/trunk/qpid/python/qpid/messaging/endpoints.py
Modified: qpid/trunk/qpid/python/qpid/messaging/endpoints.py
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/python/qpid/messaging/endpoints.py?rev=1097539&r1=1097538&r2=1097539&view=diff
==============================================================================
--- qpid/trunk/qpid/python/qpid/messaging/endpoints.py (original)
+++ qpid/trunk/qpid/python/qpid/messaging/endpoints.py Thu Apr 28 16:39:36 2011
@@ -1007,9 +1007,9 @@ class Receiver(Endpoint, object):
self.draining = True
self._wakeup()
self._ecwait(lambda: not self.draining)
+ msg = self.session._get(self, timeout=0)
self._grant()
self._wakeup()
- msg = self.session._get(self, timeout=0)
if msg is None:
raise Empty()
elif self._capacity not in (0, UNLIMITED.value):
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:commits-subscribe@qpid.apache.org