summaryrefslogtreecommitdiff
path: root/python/qpid/delegates.py
diff options
context:
space:
mode:
authorRafael H. Schloming <rhs@apache.org>2009-01-22 18:55:12 +0000
committerRafael H. Schloming <rhs@apache.org>2009-01-22 18:55:12 +0000
commit37afb4d9376558f37ea93c3b39ab66fc69370033 (patch)
treedf66f390abfb3730cd062d66f9b7bb43e3001058 /python/qpid/delegates.py
parent9b00c29e5ca198d9168c8bae71d2dd3eccbe5397 (diff)
downloadqpid-python-37afb4d9376558f37ea93c3b39ab66fc69370033.tar.gz
ensure that we always close the socket, even if the other end doesn't
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@736742 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'python/qpid/delegates.py')
-rw-r--r--python/qpid/delegates.py1
1 files changed, 1 insertions, 0 deletions
diff --git a/python/qpid/delegates.py b/python/qpid/delegates.py
index 61c8e8c326..7cfd9b11db 100644
--- a/python/qpid/delegates.py
+++ b/python/qpid/delegates.py
@@ -59,6 +59,7 @@ class Delegate:
def connection_close_ok(self, ch, close_ok):
self.connection.opened = False
+ self.connection.closed = True
notify(self.connection.condition)
def connection_heartbeat(self, ch, hrt):