From e62fbb2c3b40a38f47247570debb5f0e9012c432 Mon Sep 17 00:00:00 2001
From: Piotr Maslanka <piotr.maslanka@henrietta.com.pl>
Date: Sat, 18 Mar 2017 00:06:40 +0100
Subject: [PATCH] bugfxi duh
---
coolamqp/clustering/single.py | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/coolamqp/clustering/single.py b/coolamqp/clustering/single.py
index d902195..9219ef7 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"""
--
GitLab