diff --git a/coolamqp/cluster.py b/coolamqp/cluster.py
index 1ee71eb9709e71ffe1bbc1185ba4ed0c5cf3e3d9..e29fa918786ce68a021ebca3777dec6f0c0bc835 100644
--- a/coolamqp/cluster.py
+++ b/coolamqp/cluster.py
@@ -104,7 +104,8 @@ class Cluster(object):
             on_failed(Discarded())
             return o
             # discard at once if no point in sending
-            self.thread.order_queue.append(a)
+
+        self.thread.order_queue.append(a)
         return a
 
     def declare_exchange(self, exchange, on_completed=None, on_failed=None):