Beanstalk: Close connection on channel close.

2010-11-15 14:09:08 +01:00 · 2010-11-15 14:09:08 +01:00 · 5b7f4342b3
parent 6989b4e31a
commit 5b7f4342b3
1 changed files with 5 additions and 0 deletions
--- a/kombu/transport/beanstalk.py
+++ b/kombu/transport/beanstalk.py
@ -97,6 +97,11 @@ class Channel(virtual.Channel):
        conn.connect()
        return conn

+    def close(self):
+        if self._client is not None:
+            return self._client.close()
+        super(Channel, self).close()
+
    @property
    def client(self):
        if self._client is None: