From 6b18f206d3fe499f575464e28e10c4f465d4bc8f Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Piotr=20Ma=C5=9Blanka?= <piotr.maslanka@henrietta.com.pl>
Date: Thu, 9 Jul 2020 16:40:06 +0200
Subject: [PATCH] fix the tests
---
coolamqp/clustering/cluster.py | 9 +++------
1 file changed, 3 insertions(+), 6 deletions(-)
diff --git a/coolamqp/clustering/cluster.py b/coolamqp/clustering/cluster.py
index 9cfe3a3..35be5bb 100644
--- a/coolamqp/clustering/cluster.py
+++ b/coolamqp/clustering/cluster.py
@@ -76,6 +76,7 @@ class Cluster(object):
except ImportError:
raise RuntimeError('tracer given, but opentracing is not installed!')
+ self.started = False
self.tracer = tracer
self.name = name or 'CoolAMQP'
self.node, = nodes
@@ -282,13 +283,9 @@ class Cluster(object):
:raise RuntimeError: called more than once
:raise ConnectionDead: failed to connect within timeout
"""
-
- try:
- self.listener
- except AttributeError:
- pass
- else:
+ if self.started:
raise RuntimeError(u'[%s] This was already called!' % (self.name,))
+ self.started = True
self.listener = ListenerThread(name=self.name)
--
GitLab