Skip to content

Commit 4bd6230

Browse files
committed
tests: v5_SUITE wait longer to receive messages
1 parent 12ef011 commit 4bd6230

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

deps/rabbitmq_mqtt/test/v5_SUITE.erl

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1061,15 +1061,15 @@ send(Parent, Client, Topic, NumSent) ->
10611061
end.
10621062

10631063
assert_received_no_duplicates() ->
1064-
assert_received_no_duplicates0(#{}).
1064+
assert_received_no_duplicates0(#{}, 30000).
10651065

1066-
assert_received_no_duplicates0(Received) ->
1066+
assert_received_no_duplicates0(Received, Timeout) ->
10671067
receive {publish, #{payload := P}} ->
10681068
case maps:is_key(P, Received) of
10691069
true -> ct:fail("Received ~p twice", [P]);
1070-
false -> assert_received_no_duplicates0(maps:put(P, ok, Received))
1070+
false -> assert_received_no_duplicates0(maps:put(P, ok, Received), 500)
10711071
end
1072-
after 500 ->
1072+
after Timeout ->
10731073
%% Check that we received at least one message.
10741074
?assertNotEqual(0, maps:size(Received))
10751075
end.

0 commit comments

Comments
 (0)