summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorGordon Sim <gsim@apache.org>2011-03-01 16:16:40 +0000
committerGordon Sim <gsim@apache.org>2011-03-01 16:16:40 +0000
commitfc77e67d8542ff23321e548fa0b32d8bb3fa2f0b (patch)
treeb495316531646ef70d4104fa11cf5afb8f4ed40a
parent0f32f52376ac1a4454f2935d8f3c81ef36a26d35 (diff)
downloadqpid-python-fc77e67d8542ff23321e548fa0b32d8bb3fa2f0b.tar.gz
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
-rw-r--r--qpid/python/qpid/messaging/endpoints.py2
-rw-r--r--qpid/python/qpid/tests/messaging/endpoints.py3
2 files changed, 4 insertions, 1 deletions
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()