diff --git a/coolamqp/clustering/cluster.py b/coolamqp/clustering/cluster.py
index 3e82cedd8ac222a30b88b0516e691e7dea4aac16..14262120343a8e28b74f3c8f8e1652c899913fb1 100644
--- a/coolamqp/clustering/cluster.py
+++ b/coolamqp/clustering/cluster.py
@@ -52,7 +52,7 @@ class Cluster(object):
 
         self.node, = nodes
 
-        if self.on_fail is not None:
+        if on_fail is not None:
             def decorated():
                 if not self.listener.terminating:
                     on_fail()