QPID-7424: [Python Client 0-8..0-91] Raise Closed exception to application when connection is remotely closed.
If application is blocking a on an incoming queue we now raise a Closed exception to notify it in case the connection is closed
diff --git a/qpid/client.py b/qpid/client.py
index 91b2721..39b7c58 100644
--- a/qpid/client.py
+++ b/qpid/client.py
@@ -246,6 +246,9 @@
self.client.closed = True
self.client.reason = reason
self.client.started.set()
+ with self.client.lock:
+ for queue in self.client.queues.values():
+ queue.close(reason)
class StructFactory:
