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

Fix test case rebalance 

This test case was wrongly skipped and therefore never ran.
This commit is contained in:
David Ansari 2024-07-10 10:26:23 +00:00
parent 18e8c1d5f8
commit e31df4cd01
1 changed files with 12 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -1239,7 +1239,7 @@ recover_after_leader_and_coordinator_kill(Config) ->
ct:pal("sys state ~p", [CState]),
rabbit_ct_broker_helpers:rpc(Config, 0, ?MODULE, delete_testcase_queue, [Q]),
ok.
keep_consuming_on_leader_restart(Config) ->
@ -2194,6 +2194,7 @@ leader_locator_balanced_maintenance(Config) ->
end, 60000),
true = rabbit_ct_broker_helpers:unmark_as_being_drained(Config, Server3),
rabbit_ct_broker_helpers:rpc(Config, 0, ?MODULE, delete_queues, [[Q1, Q]]),
rabbit_ct_broker_helpers:rpc(Config, 0, ?MODULE, delete_testcase_queue, [Q]).
select_nodes_with_least_replicas(Config) ->
@ -2803,20 +2804,20 @@ rebalance(Config) ->
Q5 = <<"st5">>,
?assertEqual({'queue.declare_ok', Q1, 0, 0},
declare(Ch, Q1, [{<<"x-queue-type">>, longstr, <<"stream">>},
{<<"x-initial-cluster-size">>, long, 3}])),
declare(Config, Server0, Q1, [{<<"x-queue-type">>, longstr, <<"stream">>},
{<<"x-initial-cluster-size">>, long, 3}])),
?assertEqual({'queue.declare_ok', Q2, 0, 0},
declare(Ch, Q2, [{<<"x-queue-type">>, longstr, <<"stream">>},
{<<"x-initial-cluster-size">>, long, 3}])),
declare(Config, Server0, Q2, [{<<"x-queue-type">>, longstr, <<"stream">>},
{<<"x-initial-cluster-size">>, long, 3}])),
?assertEqual({'queue.declare_ok', Q3, 0, 0},
declare(Ch, Q3, [{<<"x-queue-type">>, longstr, <<"stream">>},
{<<"x-initial-cluster-size">>, long, 3}])),
declare(Config, Server0, Q3, [{<<"x-queue-type">>, longstr, <<"stream">>},
{<<"x-initial-cluster-size">>, long, 3}])),
?assertEqual({'queue.declare_ok', Q4, 0, 0},
declare(Ch, Q4, [{<<"x-queue-type">>, longstr, <<"stream">>},
{<<"x-initial-cluster-size">>, long, 3}])),
declare(Config, Server0, Q4, [{<<"x-queue-type">>, longstr, <<"stream">>},
{<<"x-initial-cluster-size">>, long, 3}])),
?assertEqual({'queue.declare_ok', Q5, 0, 0},
declare(Ch, Q5, [{<<"x-queue-type">>, longstr, <<"stream">>},
{<<"x-initial-cluster-size">>, long, 3}])),
declare(Config, Server0, Q5, [{<<"x-queue-type">>, longstr, <<"stream">>},
{<<"x-initial-cluster-size">>, long, 3}])),
NumMsgs = 100,
Data = crypto:strong_rand_bytes(100),