diff options
Diffstat (limited to 'python')
| -rw-r--r-- | python/qpid/messaging/driver.py | 9 |
1 files changed, 7 insertions, 2 deletions
diff --git a/python/qpid/messaging/driver.py b/python/qpid/messaging/driver.py index cf8498794b..5cf41eb455 100644 --- a/python/qpid/messaging/driver.py +++ b/python/qpid/messaging/driver.py @@ -380,6 +380,11 @@ class Driver: self.update_status() + self._notify() + + def _notify(self): + if self.connection.error: + self.connection._condition.gc() self.connection._waiter.notifyAll() def close_engine(self, e=None): @@ -434,12 +439,12 @@ class Driver: notify = True if self.update_status() or notify: - self.connection._waiter.notifyAll() + self._notify() @synchronized def timeout(self): self.dispatch() - self.connection._waiter.notifyAll() + self._notify() def dispatch(self): try: |