Skip to content

Commit a5d95e5

Browse files
authored
Merge pull request #14738 from rabbitmq/require-ff-quorum_queue_non_voters
Require feature flag `quorum_queue_non_voters`
2 parents 1547718 + 998a7ee commit a5d95e5

File tree

3 files changed

+4
-13
lines changed

3 files changed

+4
-13
lines changed

deps/rabbit/src/rabbit_core_ff.erl

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -177,9 +177,8 @@
177177

178178
-rabbit_feature_flag(
179179
{quorum_queue_non_voters,
180-
#{desc =>
181-
"Allows new quorum queue members to be added as non voters initially.",
182-
stability => stable,
180+
#{desc => "Allows new quorum queue members to be added as non voters initially.",
181+
stability => required,
183182
depends_on => [quorum_queue]
184183
}}).
185184

deps/rabbit/src/rabbit_quorum_queue.erl

Lines changed: 1 addition & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -1389,13 +1389,7 @@ do_add_member(Q, Node, Membership, Timeout)
13891389
Conf = make_ra_conf(Q, ServerId, Membership, MachineVersion),
13901390
case ra:start_server(?RA_SYSTEM, Conf) of
13911391
ok ->
1392-
ServerIdSpec =
1393-
case rabbit_feature_flags:is_enabled(quorum_queue_non_voters) of
1394-
true ->
1395-
maps:with([id, uid, membership], Conf);
1396-
false ->
1397-
maps:get(id, Conf)
1398-
end,
1392+
ServerIdSpec = maps:with([id, uid, membership], Conf),
13991393
case ra:add_member(Members, ServerIdSpec, Timeout) of
14001394
{ok, {RaIndex, RaTerm}, Leader} ->
14011395
Fun = fun(Q1) ->

deps/rabbit/test/quorum_queue_SUITE.erl

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -2810,10 +2810,8 @@ add_member(Config) ->
28102810

28112811
add_member_2(Config) ->
28122812
%% this tests a scenario where an older node version is running a QQ
2813-
%% and a member is added on a newer node version (for mixe testing)
2813+
%% and a member is added on a newer node version (for mixed testing)
28142814

2815-
%% we dont validate the ff was enabled as this test should pass either way
2816-
_ = rabbit_ct_broker_helpers:enable_feature_flag(Config, quorum_queue_non_voters),
28172815
[Server0, Server1 | _] = _Servers0 =
28182816
rabbit_ct_broker_helpers:get_node_configs(Config, nodename),
28192817
Ch = rabbit_ct_client_helpers:open_channel(Config, Server1),

0 commit comments

Comments
 (0)