diff --git a/coolamqp/clustering/single.py b/coolamqp/clustering/single.py index 05ed0e92634dc95ee526ae7dbd07bdac628e9ac4..f635163107fcbe63dbc368ee3e35dec5e940673b 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 f7fe4c6077fe797bf56791b0a4d71251980a309b..57fc7b1f5201b349ec4f9a1e3659ca6b077cecc2 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 19d15cf510d2c6b9cbd0f5339214875e3f0e5087..de1aa0d9bcfcbf23f1ba8d84d802bb298f91fac6 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)