diff options
Diffstat (limited to 'python/qpid/messaging/endpoints.py')
| -rw-r--r-- | python/qpid/messaging/endpoints.py | 7 |
1 files changed, 4 insertions, 3 deletions
diff --git a/python/qpid/messaging/endpoints.py b/python/qpid/messaging/endpoints.py index f989d6c918..7d7d4249a3 100644 --- a/python/qpid/messaging/endpoints.py +++ b/python/qpid/messaging/endpoints.py @@ -1009,8 +1009,9 @@ class Receiver(Endpoint, object): if msg is None: raise Empty() elif self._capacity not in (0, UNLIMITED.value): - if self.received - self.returned <= int(ceil(self.threshold * self._capacity)): - self.granted = self.received + self._capacity + t = int(ceil(self.threshold * self._capacity)) + if self.received - self.returned <= t: + self.granted = self.returned + self._capacity self._wakeup() return msg @@ -1018,7 +1019,7 @@ class Receiver(Endpoint, object): if self._capacity == UNLIMITED.value: self.granted = UNLIMITED else: - self.granted = self.received + self._capacity + self.granted = self.returned + self._capacity @synchronized def close(self, timeout=None): |