Skip to content

Commit d629672

Browse files
committed
bindings_SUITE: Wait for previous tests clean up to be replicated
1 parent 7c9bcdb commit d629672

File tree

1 file changed

+4
-2
lines changed

1 file changed

+4
-2
lines changed

deps/rabbit/test/bindings_SUITE.erl

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -819,10 +819,12 @@ transient_queue_on_node_down(Config) ->
819819
QAltResource = rabbit_misc:r(<<"/">>, queue, QAlt),
820820
DefaultBinding = binding_record(DefaultExchange, QResource, Q, []),
821821
DefaultAltBinding = binding_record(DefaultExchange, QAltResource, QAlt, []),
822+
DefaultBindings = lists:sort([DefaultBinding, DefaultAltBinding]),
822823

823824
%% Binding to the default exchange, it's always present
824-
?assertEqual(lists:sort([DefaultBinding, DefaultAltBinding]),
825-
lists:sort(rabbit_ct_broker_helpers:rpc(Config, 1, rabbit_binding, list, [<<"/">>]))),
825+
?awaitMatch(DefaultBindings,
826+
lists:sort(rabbit_ct_broker_helpers:rpc(Config, 1, rabbit_binding, list, [<<"/">>])),
827+
30000),
826828

827829
%% Let's bind to other exchange
828830
#'queue.bind_ok'{} = amqp_channel:call(Ch, #'queue.bind'{exchange = <<"amq.direct">>,

0 commit comments

Comments
 (0)