diff --git a/kombu/transport/pyredis.py b/kombu/transport/pyredis.py
index c960177c..cbf269e8 100644
--- a/kombu/transport/pyredis.py
+++ b/kombu/transport/pyredis.py
@@ -14,6 +14,7 @@ from Queue import Empty, Queue as _Queue
 from anyjson import serialize, deserialize
 
 from kombu.transport import virtual
+from kombu.utils.finalize import Finalize
 
 DEFAULT_PORT = 6379
 DEFAULT_DB = 0
@@ -40,6 +41,8 @@ class ChannelPoller(Thread):
         self.poll_request = Condition(self.mutex)
         self.shutdown = Event()
         self.stopped = Event()
+        self._on_collect = Finalize(self, self.close)
+
         Thread.__init__(self)
         self.setDaemon(False)
         self.started = False