Skip to content

Commit bc3605b

Browse files
committed
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
1 parent 15ccef2 commit bc3605b

File tree

1 file changed

+3
-0
lines changed

1 file changed

+3
-0
lines changed

qpid/client.py

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -246,6 +246,9 @@ def closed(self, reason):
246246
self.client.closed = True
247247
self.client.reason = reason
248248
self.client.started.set()
249+
with self.client.lock:
250+
for queue in self.client.queues.values():
251+
queue.close(reason)
249252

250253
class StructFactory:
251254

0 commit comments

Comments
 (0)