Skip to content

Commit e9a8949

Browse files
author
Loïc Hoguin
committed
Revert "Default to classic queues v2"
This reverts commit a404b49.
1 parent 7b1e2c0 commit e9a8949

File tree

6 files changed

+4
-24
lines changed

6 files changed

+4
-24
lines changed

deps/rabbit/BUILD.bazel

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -85,8 +85,6 @@ _APP_ENV = """[
8585
]},
8686
{halt_on_upgrade_failure, true},
8787
{ssl_apps, [asn1, crypto, public_key, ssl]},
88-
%% classic queue storage implementation version
89-
{classic_queue_default_version, 2},
9088
%% see rabbitmq-server#114
9189
{mirroring_flow_control, true},
9290
{mirroring_sync_batch_size, 4096},

deps/rabbit/Makefile

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -65,8 +65,6 @@ define PROJECT_ENV
6565
]},
6666
{halt_on_upgrade_failure, true},
6767
{ssl_apps, [asn1, crypto, public_key, ssl]},
68-
%% classic queue storage implementation version
69-
{classic_queue_default_version, 2},
7068
%% see rabbitmq-server#114
7169
{mirroring_flow_control, true},
7270
{mirroring_sync_batch_size, 4096},

deps/rabbit/priv/schema/rabbit.schema

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2485,7 +2485,7 @@ end}.
24852485

24862486
{translation, "rabbit.classic_queue_default_version",
24872487
fun(Conf) ->
2488-
case cuttlefish:conf_get("classic_queue.default_version", Conf, 2) of
2488+
case cuttlefish:conf_get("classic_queue.default_version", Conf, 1) of
24892489
1 -> 1;
24902490
2 -> 2;
24912491
_ -> cuttlefish:unset()

deps/rabbit/src/rabbit_amqqueue_process.erl

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -470,12 +470,12 @@ init_queue_mode(Mode, State = #q {backing_queue = BQ,
470470

471471
init_queue_version(Version0, State = #q {backing_queue = BQ,
472472
backing_queue_state = BQS}) ->
473-
%% When the version is undefined we use the default version 2.
473+
%% When the version is undefined we use the default version 1.
474474
%% We want to BQ:set_queue_version in all cases because a v2
475475
%% policy might have been deleted, for example, and we want
476476
%% the queue to go back to v1.
477477
Version = case Version0 of
478-
undefined -> rabbit_misc:get_env(rabbit, classic_queue_default_version, 2);
478+
undefined -> rabbit_misc:get_env(rabbit, classic_queue_default_version, 1);
479479
_ -> Version0
480480
end,
481481
BQS1 = BQ:set_queue_version(Version, BQS),

deps/rabbit/src/rabbit_variable_queue.erl

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -489,11 +489,10 @@ process_recovery_terms(Terms) ->
489489
PRef -> {PRef, Terms}
490490
end.
491491

492-
%% If queue-version is undefined, we assume v2 starting with RabbitMQ 3.13.0.
493492
queue_version(Q) ->
494493
Resolve = fun(_, ArgVal) -> ArgVal end,
495494
case rabbit_queue_type_util:args_policy_lookup(<<"queue-version">>, Resolve, Q) of
496-
undefined -> rabbit_misc:get_env(rabbit, classic_queue_default_version, 2);
495+
undefined -> rabbit_misc:get_env(rabbit, classic_queue_default_version, 1);
497496
Vsn when is_integer(Vsn) -> Vsn;
498497
Vsn -> binary_to_integer(Vsn)
499498
end.

release-notes/3.13.0.md

Lines changed: 0 additions & 15 deletions
Original file line numberDiff line numberDiff line change
@@ -240,21 +240,6 @@ Release notes are kept under [rabbitmq-server/release-notes](https://github.com/
240240

241241
GitHub issue: [#8218](https://github.com/rabbitmq/rabbitmq-server/pull/8218)
242242

243-
* Reduced memory footprint, improved memory use predictability and throughput of classic queues (version 2, or CQv2).
244-
This particularly benefits classic queues with longer backlogs.
245-
246-
Classic queue v2 (CQv2) storage implementation **is now the default**. It is possible to switch
247-
the default back to CQv1 using `rabbitmq.conf`:
248-
249-
``` ini
250-
# uses CQv1 by default
251-
classic_queue.default_version = 1
252-
```
253-
254-
Individual queues can be declared by passing `x-queue-version` argument and/or through a `queue-version` policy.
255-
256-
GitHub issue: [#8308](https://github.com/rabbitmq/rabbitmq-server/pull/8308)
257-
258243
* Revisited peer discovery implementation that further reduces the probability of two or more
259244
sets of nodes [forming separate clusters](https://www.rabbitmq.com/cluster-formation.html#initial-formation-race-condition) when **all** cluster nodes are created at the same time and boot in parallel.
260245

0 commit comments

Comments
 (0)