qpid-python git commit: QPID-7424: [Python Client 0-8..0-91] Raise Closed exception to application when connection is remotely closed.

[or...@apache.org]

Repository: qpid-python
Updated Branches:
  refs/heads/master 15ccef2df -> bc3605bc8


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


Project: http://git-wip-us.apache.org/repos/asf/qpid-python/repo
Commit: http://git-wip-us.apache.org/repos/asf/qpid-python/commit/bc3605bc
Tree: http://git-wip-us.apache.org/repos/asf/qpid-python/tree/bc3605bc
Diff: http://git-wip-us.apache.org/repos/asf/qpid-python/diff/bc3605bc

Branch: refs/heads/master
Commit: bc3605bc8829510c65cde8c2ebe178bd6bbcb155
Parents: 15ccef2
Author: Alex Rudyy <or...@apache.org>
Authored: Wed Sep 14 15:08:29 2016 +0100
Committer: Alex Rudyy <or...@apache.org>
Committed: Wed Sep 14 15:11:32 2016 +0100

----------------------------------------------------------------------
 qpid/client.py | 3 +++
 1 file changed, 3 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/qpid-python/blob/bc3605bc/qpid/client.py
----------------------------------------------------------------------
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 @@ class ClientDelegate(Delegate):
     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:
 


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org