diff --git a/coolamqp/clustering/cluster.py b/coolamqp/clustering/cluster.py
index 3ec9cc6cd1b6aa260842ba43fb3110cd68ef2d16..dfa1d9a717d2fb30340b243ba2058d9f473139d2 100644
--- a/coolamqp/clustering/cluster.py
+++ b/coolamqp/clustering/cluster.py
@@ -259,7 +259,7 @@ class Cluster(object):
         :param wait: block until this is done
         :raise RuntimeError: if called without start() being called first
         """
-
+        self.connected = False
         try:
             self.listener
         except AttributeError: