Author: gsim
Date: Tue Mar 1 16:16:40 2011
New Revision: 1075876
URL: http://svn.apache.org/viewvc?rev=1075876&view=rev
Log:
QPID-3063: test correct variable in check_close()
Modified:
qpid/trunk/qpid/python/qpid/messaging/endpoints.py
qpid/trunk/qpid/python/qpid/tests/messaging/endpoints.py
Modified: qpid/trunk/qpid/python/qpid/messaging/endpoints.py
URL:
http://svn.apache.org/viewvc/qpid/trunk/qpid/python/qpid/messaging/endpoints.py?rev=1075876&r1=1075875&r2=1075876&view=diff
==============================================================================
--- qpid/trunk/qpid/python/qpid/messaging/endpoints.py (original)
+++ qpid/trunk/qpid/python/qpid/messaging/endpoints.py Tue Mar 1 16:16:40 2011
@@ -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()
Modified: qpid/trunk/qpid/python/qpid/tests/messaging/endpoints.py
URL:
http://svn.apache.org/viewvc/qpid/trunk/qpid/python/qpid/tests/messaging/endpoints.py?rev=1075876&r1=1075875&r2=1075876&view=diff
==============================================================================
--- qpid/trunk/qpid/python/qpid/tests/messaging/endpoints.py (original)
+++ qpid/trunk/qpid/python/qpid/tests/messaging/endpoints.py Tue Mar 1
16:16:40 2011
@@ -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()
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:[email protected]
