root
/
rabbitmq-server
mirror of https://github.com/rabbitmq/rabbitmq-server.git
1
0
Fork 0
Code Issues Actions 1 Packages Projects Releases Wiki Activity

Make a test less flaky; formatting

This commit is contained in:
Michal Kuratczyk 2022-12-22 14:59:47 +01:00
parent 4160dac33e
commit 44ed4eb340
No known key found for this signature in database
1 changed files with 10 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
deps/rabbit/test/rabbit_stream_queue_SUITE.erl vendored
View File

@ -360,9 +360,9 @@ declare_queue(Config) ->
%% Test declare an existing queue %% Test declare an existing queue
?assertEqual({'queue.declare_ok', Q, 0, 0}, ?assertEqual({'queue.declare_ok', Q, 0, 0},
declare(Ch, Q, [{<<"x-queue-type">>, longstr, <<"stream">>}])), declare(Ch, Q, [{<<"x-queue-type">>, longstr, <<"stream">>}])),
?assertMatch([_], find_queue_info(Config, [])), ?assertMatch([_], find_queue_info(Config, [])),
%% Test declare an existing queue with different arguments %% Test declare an existing queue with different arguments
?assertExit(_, declare(Ch, Q, [])), ?assertExit(_, declare(Ch, Q, [])),
rabbit_ct_broker_helpers:rpc(Config, 0, ?MODULE, delete_testcase_queue, [Q]). rabbit_ct_broker_helpers:rpc(Config, 0, ?MODULE, delete_testcase_queue, [Q]).
@ -1075,7 +1075,7 @@ consume_and_nack(Config) ->
multiple = false, multiple = false,
requeue = true}), requeue = true}),
%% Nack will throw a not implemented exception. As it is a cast operation, %% Nack will throw a not implemented exception. As it is a cast operation,
%% we'll detect the conneciton/channel closure on the next call. %% we'll detect the conneciton/channel closure on the next call.
%% Let's try to redeclare and see what happens %% Let's try to redeclare and see what happens
?assertExit({{shutdown, {connection_closing, {server_initiated_close, 540, _}}}, _}, ?assertExit({{shutdown, {connection_closing, {server_initiated_close, 540, _}}}, _},
declare(Ch1, Q, [{<<"x-queue-type">>, longstr, <<"stream">>}])) declare(Ch1, Q, [{<<"x-queue-type">>, longstr, <<"stream">>}]))
@ -1299,7 +1299,7 @@ consume_and_reject(Config) ->
ok = amqp_channel:cast(Ch1, #'basic.reject'{delivery_tag = DeliveryTag, ok = amqp_channel:cast(Ch1, #'basic.reject'{delivery_tag = DeliveryTag,
requeue = true}), requeue = true}),
%% Reject will throw a not implemented exception. As it is a cast operation, %% Reject will throw a not implemented exception. As it is a cast operation,
%% we'll detect the conneciton/channel closure on the next call. %% we'll detect the conneciton/channel closure on the next call.
%% Let's try to redeclare and see what happens %% Let's try to redeclare and see what happens
?assertExit({{shutdown, {connection_closing, {server_initiated_close, 540, _}}}, _}, ?assertExit({{shutdown, {connection_closing, {server_initiated_close, 540, _}}}, _},
declare(Ch1, Q, [{<<"x-queue-type">>, longstr, <<"stream">>}])) declare(Ch1, Q, [{<<"x-queue-type">>, longstr, <<"stream">>}]))
@ -1710,7 +1710,12 @@ max_length_bytes(Config) ->
Payload = << <<"1">> || _ <- lists:seq(1, 100) >>, Payload = << <<"1">> || _ <- lists:seq(1, 100) >>,
publish_confirm(Ch, Q, [Payload || _ <- lists:seq(1, 500)]), %% 100 bytes/msg * 500 = 50000 bytes %% 100 bytes/msg * 500 = 50000 bytes
publish_confirm(Ch, Q, [Payload || _ <- lists:seq(1, 100)]),
publish_confirm(Ch, Q, [Payload || _ <- lists:seq(1, 100)]),
publish_confirm(Ch, Q, [Payload || _ <- lists:seq(1, 100)]),
publish_confirm(Ch, Q, [Payload || _ <- lists:seq(1, 100)]),
publish_confirm(Ch, Q, [Payload || _ <- lists:seq(1, 100)]),
ensure_retention_applied(Config, Server), ensure_retention_applied(Config, Server),
%% We don't yet have reliable metrics, as the committed offset doesn't work %% We don't yet have reliable metrics, as the committed offset doesn't work