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

Return immediately for leader health checks on empty vhosts

This commit is contained in:
Ayanda Dube 2024-07-18 15:55:36 +01:00
parent 48ba3e161f
commit 7873737b35
2 changed files with 9 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
deps/rabbit/src/rabbit_quorum_queue.erl vendored
View File

@ -2196,6 +2196,7 @@ run_leader_health_check(ClusterName, QResource, HealthCheckRef, From) ->
end,
ok.
wait_for_leader_health_checks(_Ref, 0, UnhealthyAcc = []) -> UnhealthyAcc;
wait_for_leader_health_checks(Ref, N, UnhealthyAcc) ->
receive
{ok, Ref, _QResource} when N == 1 ->

8
deps/rabbit/test/quorum_queue_SUITE.erl vendored
View File

@ -4153,6 +4153,14 @@ leader_health_check(Config) ->
set_up_vhost(Config, VHost1),
set_up_vhost(Config, VHost2),
%% check empty vhost
?assertEqual([],
rabbit_ct_broker_helpers:rpc(Config, 0, rabbit_quorum_queue, leader_health_check,
[<<".*">>, VHost1])),
?assertEqual([],
rabbit_ct_broker_helpers:rpc(Config, 0, rabbit_quorum_queue, leader_health_check,
[<<".*">>, global])),
Conn1 = rabbit_ct_client_helpers:open_unmanaged_connection(Config, 0, VHost1),
{ok, Ch1} = amqp_connection:open_channel(Conn1),