Skip to content

Commit c7845f8

Browse files
author
Loïc Hoguin
committed
CQ: Remove compat code for classic_mirrored_queue_version
1 parent 58aa1b0 commit c7845f8

File tree

2 files changed

+3
-9
lines changed

2 files changed

+3
-9
lines changed

deps/rabbit/src/rabbit_core_ff.erl

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -10,7 +10,6 @@
1010
-rabbit_feature_flag(
1111
{classic_mirrored_queue_version,
1212
#{desc => "Support setting version for classic mirrored queues",
13-
%%TODO remove compatibility code
1413
stability => required
1514
}}).
1615

deps/rabbit/src/rabbit_mirror_queue_master.erl

Lines changed: 3 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -494,14 +494,9 @@ set_queue_mode(Mode, State = #state { gm = GM,
494494
set_queue_version(Version, State = #state { gm = GM,
495495
backing_queue = BQ,
496496
backing_queue_state = BQS }) ->
497-
case rabbit_feature_flags:is_enabled(classic_mirrored_queue_version) of
498-
true ->
499-
ok = gm:broadcast(GM, {set_queue_version, Version}),
500-
BQS1 = BQ:set_queue_version(Version, BQS),
501-
State #state { backing_queue_state = BQS1 };
502-
false ->
503-
State
504-
end.
497+
ok = gm:broadcast(GM, {set_queue_version, Version}),
498+
BQS1 = BQ:set_queue_version(Version, BQS),
499+
State #state { backing_queue_state = BQS1 }.
505500

506501
zip_msgs_and_acks(Msgs, AckTags, Accumulator,
507502
#state { backing_queue = BQ,

0 commit comments

Comments
 (0)