diff --git a/coolamqp/uplink/listener/thread.py b/coolamqp/uplink/listener/thread.py
index 7fda4fe1b8dbecd8952d0b71f037e0970c3ef77a..c7cad123889304e581e72449e8c56771d958d5b0 100644
--- a/coolamqp/uplink/listener/thread.py
+++ b/coolamqp/uplink/listener/thread.py
@@ -38,6 +38,9 @@ class ListenerThread(threading.Thread):
         """Called before start. It is not safe to fork after this"""
         self.listener = EpollListener()
 
+    def activate(self, sock):
+        self.listener.activate(sock)
+
     def run(self):
         while not self.terminating:
             self.listener.wait(timeout=1)