From f42aec509ac057b3dc364cf9800359d22ad040c4 Mon Sep 17 00:00:00 2001 From: Piotr Maslanka <piotr.maslanka@henrietta.com.pl> Date: Tue, 10 Jan 2017 06:44:27 +0100 Subject: [PATCH] heh travis rmq --- coolamqp/clustering/single.py | 1 + tests/run.py | 2 +- tests/test_clustering/test_a.py | 4 ++-- 3 files changed, 4 insertions(+), 3 deletions(-) diff --git a/coolamqp/clustering/single.py b/coolamqp/clustering/single.py index 05ed0e9..f635163 100644 --- a/coolamqp/clustering/single.py +++ b/coolamqp/clustering/single.py @@ -43,6 +43,7 @@ class SingleNodeReconnector(object): def shutdown(self): """Close this connection""" self.terminating = True + if self.connection is not None: self.connection.send(None) self.connection = None diff --git a/tests/run.py b/tests/run.py index f7fe4c6..57fc7b1 100644 --- a/tests/run.py +++ b/tests/run.py @@ -7,7 +7,7 @@ from coolamqp.clustering import Cluster import time -NODE = NodeDefinition('127.0.0.1', 'user', 'user', heartbeat=20) +NODE = NodeDefinition('127.0.0.1', 'guest', 'guest', heartbeat=20) logging.basicConfig(level=logging.DEBUG) if __name__ == '__main__': diff --git a/tests/test_clustering/test_a.py b/tests/test_clustering/test_a.py index 19d15cf..de1aa0d 100644 --- a/tests/test_clustering/test_a.py +++ b/tests/test_clustering/test_a.py @@ -11,8 +11,8 @@ from coolamqp.clustering import Cluster import time - -NODE = NodeDefinition('127.0.0.1', 'user', 'user', heartbeat=20) +#todo handle bad auth +NODE = NodeDefinition('127.0.0.1', 'guest', 'guest', heartbeat=20) logging.basicConfig(level=logging.DEBUG) -- GitLab