From 2aadc44e07e1d6f23cecaf3c65a29807a1fa602c Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Piotr=20Ma=C5=9Blanka?= <piotr.maslanka@henrietta.com.pl>
Date: Wed, 23 Oct 2019 08:30:47 +0200
Subject: [PATCH] Fixed #7
---
coolamqp/uplink/connection/connection.py | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/coolamqp/uplink/connection/connection.py b/coolamqp/uplink/connection/connection.py
index e1ea187..fb35aa4 100644
--- a/coolamqp/uplink/connection/connection.py
+++ b/coolamqp/uplink/connection/connection.py
@@ -140,7 +140,7 @@ class Connection(object):
(self.node_definition.host, self.node_definition.port))
except socket.error as e:
time.sleep(0.5) # Connection refused? Very bad things?
- if monotonic.monotonic() - start_at < timeout:
+ if monotonic.monotonic() - start_at > timeout:
raise ConnectionDead()
else:
break
--
GitLab