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 <[email protected]> Authored: Wed Sep 14 15:08:29 2016 +0100 Committer: Alex Rudyy <[email protected]> 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: [email protected] For additional commands, e-mail: [email protected]
