Author: kgiusti
Date: Thu Feb 2 14:41:26 2012
New Revision: 1239648
URL: http://svn.apache.org/viewvc?rev=1239648&view=rev
Log:
QPID-3798: do not wait indefinately for connection close.
Modified:
qpid/trunk/qpid/extras/qmf/src/py/qmf/console.py
Modified: qpid/trunk/qpid/extras/qmf/src/py/qmf/console.py
URL:
http://svn.apache.org/viewvc/qpid/trunk/qpid/extras/qmf/src/py/qmf/console.py?rev=1239648&r1=1239647&r2=1239648&view=diff
==============================================================================
--- qpid/trunk/qpid/extras/qmf/src/py/qmf/console.py (original)
+++ qpid/trunk/qpid/extras/qmf/src/py/qmf/console.py Thu Feb 2 14:41:26 2012
@@ -2412,7 +2412,7 @@ class Broker(Thread):
try:
if self.conn:
- self.conn.close()
+ self.conn.close(5)
except:
pass
self.conn = None
@@ -2713,7 +2713,7 @@ class Broker(Thread):
self.amqpSession = None
try:
if self.conn:
- self.conn.close()
+ self.conn.close(_timeout)
except:
pass
self.conn = None
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:[email protected]
