diff --git a/tests/test_clustering/test_a.py b/tests/test_clustering/test_a.py
index 3c9884591b7ca23aba30d2160f718072e8a119a1..8383c0548cc42a4dce52247fb0a226b30aa9f20c 100644
--- a/tests/test_clustering/test_a.py
+++ b/tests/test_clustering/test_a.py
@@ -265,7 +265,7 @@ class TestA(unittest.TestCase):
             Queue(u'helloA', exclusive=True, auto_delete=True))
         fut.result()
 
-        self.c.publish(Message(b'ioi'), routing_key=u'helloA')
+        self.c.publish(Message(b'ioi'), routing_key=u'helloA', confirm=True).result()
 
         self.assertIsInstance(self.c.drain(2), MessageReceived)
         self.assertIsInstance(self.c.drain(1), NothingMuch)