diff options
Diffstat (limited to 'qpid/python')
| -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 58349deb69..e69d7a10ae 100644 --- a/qpid/python/qpid/messaging/endpoints.py +++ b/qpid/python/qpid/messaging/endpoints.py @@ -1039,7 +1039,7 @@ class Receiver(Endpoint, object): self.check_closed() self.draining = True self._wakeup() - self._ecwait(lambda: not self.draining, timeout=0) + self._ecwait(lambda: not self.draining) msg = self.session._get(self, timeout=0) self._grant() self._wakeup() |