diff options
| author | Kenneth Anthony Giusti <kgiusti@apache.org> | 2012-02-02 14:41:26 +0000 |
|---|---|---|
| committer | Kenneth Anthony Giusti <kgiusti@apache.org> | 2012-02-02 14:41:26 +0000 |
| commit | e010c8adf575dd98b1ca0f579b9c7740124c75b6 (patch) | |
| tree | 0445e9bcc59d061268c6c255c244abce66e7a3f6 /extras | |
| parent | 5e2917f0424e4cfd25d2af17668640b5ed3e6cee (diff) | |
| download | qpid-python-e010c8adf575dd98b1ca0f579b9c7740124c75b6.tar.gz | |
QPID-3798: do not wait indefinately for connection close.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1239648 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'extras')
| -rw-r--r-- | extras/qmf/src/py/qmf/console.py | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/extras/qmf/src/py/qmf/console.py b/extras/qmf/src/py/qmf/console.py index e8be643c0f..0d72dc7609 100644 --- a/extras/qmf/src/py/qmf/console.py +++ b/extras/qmf/src/py/qmf/console.py @@ -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 |