Stricter setup in the confirms_survive_* tests

Wait until at least one message has been confirmed before triggering the survivable change

1 files changed, 16 insertions, 0 deletions

diff --git a/test/simple_ha_SUITE.erl b/test/simple_ha_SUITE.erl
index 7cf21a92eb..10d8eda9ee 100644
--- a/test/simple_ha_SUITE.erl
+++ b/test/simple_ha_SUITE.erl
@@ -259,6 +259,22 @@ confirms_survive(Config, DeathFun) ->
                                                     auto_delete = false,
                                                     durable     = true}),
 
+    %% send one message to ensure the channel is flowing
+    amqp_channel:register_confirm_handler(Node1Channel, self()),
+    #'confirm.select_ok'{} = amqp_channel:call(Node1Channel, #'confirm.select'{}),
+
+    Payload = <<"initial message">>,
+    ok = amqp_channel:call(Node1Channel,
+                           #'basic.publish'{routing_key = Queue},
+                           #amqp_msg{payload = Payload}),
+
+    ok = receive
+             #'basic.ack'{multiple = false} -> ok;
+             #'basic.nack'{multiple = false} -> message_nacked
+         after
+             5000 -> confirm_not_received
+         end,
+
     %% send a bunch of messages from the producer
     ProducerPid = rabbit_ha_test_producer:create(Node2Channel, Queue,
                                                  self(), true, Msgs),