From fc77e67d8542ff23321e548fa0b32d8bb3fa2f0b Mon Sep 17 00:00:00 2001 From: Gordon Sim Date: Tue, 1 Mar 2011 16:16:40 +0000 Subject: QPID-3063: test correct variable in check_close() git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1075876 13f79535-47bb-0310-9956-ffa450edef68 --- qpid/python/qpid/messaging/endpoints.py | 2 +- qpid/python/qpid/tests/messaging/endpoints.py | 3 +++ 2 files changed, 4 insertions(+), 1 deletion(-) diff --git a/qpid/python/qpid/messaging/endpoints.py b/qpid/python/qpid/messaging/endpoints.py index b8101b76e6..30c5850397 100644 --- a/qpid/python/qpid/messaging/endpoints.py +++ b/qpid/python/qpid/messaging/endpoints.py @@ -197,7 +197,7 @@ class Connection(Endpoint): return result def check_closed(self): - if self.closed: + if not self._connected: self._condition.gc() raise ConnectionClosed() diff --git a/qpid/python/qpid/tests/messaging/endpoints.py b/qpid/python/qpid/tests/messaging/endpoints.py index c303ca652a..0977b2ab3a 100644 --- a/qpid/python/qpid/tests/messaging/endpoints.py +++ b/qpid/python/qpid/tests/messaging/endpoints.py @@ -186,6 +186,9 @@ class ConnectionTests(Base): def setup_connection(self): return Connection.establish(self.broker, **self.connection_options()) + def testCheckClosed(self): + assert not self.conn.check_closed() + def testSessionAnon(self): ssn1 = self.conn.session() ssn2 = self.conn.session() -- cgit v1.2.1