diff --git a/coolamqp/clustering/single.py b/coolamqp/clustering/single.py
index d902195ba1543a0d76bb41e9aa74bbfe2b12cc75..9219ef71051f4114cd7b5d8804848e632aeccdd4 100644
--- a/coolamqp/clustering/single.py
+++ b/coolamqp/clustering/single.py
@@ -43,7 +43,7 @@ class SingleNodeReconnector(object):
             return
 
         self.connection = None
-        self.call_next_io_event(self.connect)
+        self.listener_thread.call_next_io_event(self.connect)
 
     def shutdown(self):
         """Close this connection"""