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 | 5891c343a7854cbfcd0e8cf8b1a6ae8203bcb735 (patch) | |
| tree | 35d7f845901eb06bbf9415e16e1cd650264b0c48 /python | |
| parent | a31ef2eb841fbb4a8667363757c2f3dcb694466d (diff) | |
| download | qpid-python-5891c343a7854cbfcd0e8cf8b1a6ae8203bcb735.tar.gz | |
QPID-3232: Call _grant() & wakeup() after returned message has been counted
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1097539 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'python')
| -rw-r--r-- | python/qpid/messaging/endpoints.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/python/qpid/messaging/endpoints.py b/python/qpid/messaging/endpoints.py index cfc89d4e2b..338ac70ecf 100644 --- a/python/qpid/messaging/endpoints.py +++ b/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): |