quorum_queue_SUITE

Author: dumbbell

deps/rabbitmq_ct_helpers/src/queue_utils.erl

@@ -2,6 +2,8 @@
 
 -include_lib("eunit/include/eunit.hrl").
 
+-include("include/rabbit_assert.hrl").
+
 -export([
          wait_for_messages_ready/3,
          wait_for_messages_pending_ack/3,
@@ -201,7 +203,12 @@ assert_number_of_replicas(Config, Server, VHost, QQ, Count) ->
             mnesia ->
                 ok
         end,
-    {ok, Q} = rabbit_ct_broker_helpers:rpc(
-                Config, Server, rabbit_amqqueue, lookup, [QQ, VHost]),
-    #{nodes := Nodes} = amqqueue:get_type_state(Q),
-    ?assertEqual(Count, length(Nodes)).
+    ?awaitMatch(
+       Count,
+       begin
+           {ok, Q} = rabbit_ct_broker_helpers:rpc(
+                       Config, Server, rabbit_amqqueue, lookup, [QQ, VHost]),
+           #{nodes := Nodes} = amqqueue:get_type_state(Q),
+           length(Nodes)
+       end,
+       30000).