diff options
| author | Gordon Sim <gsim@apache.org> | 2011-04-28 16:39:36 +0000 |
|---|---|---|
| committer | Gordon Sim <gsim@apache.org> | 2011-04-28 16:39:36 +0000 |
| commit | 9decaeceb333be46bbea4c645e32bf4e32f89504 (patch) | |
| tree | bd60d355db6b68486f0b6259d0495e41b12ad08b | |
| parent | 3031d0e2e212948383191490fc06a8284bee38eb (diff) | |
| download | qpid-python-9decaeceb333be46bbea4c645e32bf4e32f89504.tar.gz | |
QPID-3232: Call _grant() & wakeup() after returned message has been counted
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1097539 13f79535-47bb-0310-9956-ffa450edef68
| -rw-r--r-- | qpid/python/qpid/messaging/endpoints.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/qpid/python/qpid/messaging/endpoints.py b/qpid/python/qpid/messaging/endpoints.py index cfc89d4e2b..338ac70ecf 100644 --- a/qpid/python/qpid/messaging/endpoints.py +++ b/qpid/python/qpid/messaging/endpoints.py @@ -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): |