Skip to content

Commit da5d42b

Browse files
AMQP 0-9-1 client, core quorum_queue_SUITE: fix a few test flakes
1 parent 5825e0b commit da5d42b

2 files changed

Lines changed: 7 additions & 6 deletions

File tree

deps/amqp_client/test/system_SUITE.erl

Lines changed: 7 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -749,13 +749,15 @@ channel_multi_open_close(Config) ->
749749
ok -> ok;
750750
closing -> ok
751751
catch
752-
exit:{noproc, _} -> ok;
753-
exit:{normal, _} -> ok
752+
exit:{noproc, _} -> ok;
753+
exit:{normal, _} -> ok;
754+
exit:{{shutdown, _}, _} -> ok
754755
end;
755756
closing -> ok
756757
catch
757-
exit:{noproc, _} -> ok;
758-
exit:{normal, _} -> ok
758+
exit:{noproc, _} -> ok;
759+
exit:{normal, _} -> ok;
760+
exit:{{shutdown, _}, _} -> ok
759761
end
760762
end) || _ <- lists:seq(1, 50)],
761763
erlang:yield(),
@@ -1196,7 +1198,7 @@ default_consumer(Config) ->
11961198
receive
11971199
{#'basic.deliver'{}, #'amqp_msg'{payload = Payload}} ->
11981200
ok
1199-
after 1000 ->
1201+
after 30000 ->
12001202
exit('default_consumer_didnt_work')
12011203
end,
12021204
teardown(Connection, Channel).

deps/rabbit/test/quorum_queue_SUITE.erl

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -4500,7 +4500,6 @@ queue_length_limit_policy_cleared(Config) ->
45004500
Config, 0, <<"max-length">>, QQ, <<"queues">>,
45014501
[{<<"max-length">>, 2},
45024502
{<<"overflow">>, <<"reject-publish">>}]),
4503-
timer:sleep(1000),
45044503
RaName = ra_name(QQ),
45054504
% QueryFun = fun rabbit_fifo:overview/1,
45064505
?awaitMatch({ok, #{machine := #{config := #{max_length := 2}}}, _},

0 commit comments

Comments
 (0)