Skip to content

Commit

Permalink
Reject CQv1 in rabbit.schema and more cleanup
Browse files Browse the repository at this point in the history
  • Loading branch information
lhoguin committed Mar 12, 2024
1 parent 4514411 commit 2723dad
Show file tree
Hide file tree
Showing 4 changed files with 3 additions and 16 deletions.
2 changes: 1 addition & 1 deletion deps/rabbit/priv/schema/rabbit.schema
Original file line number Diff line number Diff line change
Expand Up @@ -2505,7 +2505,7 @@ end}.
{translation, "rabbit.classic_queue_default_version",
fun(Conf) ->
case cuttlefish:conf_get("classic_queue.default_version", Conf, 2) of
1 -> 1;
1 -> cuttlefish:invalid("Classic queues v1 are no longer supported");
2 -> 2;
_ -> cuttlefish:unset()
end
Expand Down
9 changes: 0 additions & 9 deletions deps/rabbit/test/backing_queue_SUITE.erl
Original file line number Diff line number Diff line change
Expand Up @@ -123,10 +123,6 @@ init_per_group1(backing_queue_tests, Config) ->
"Backing queue module not supported by this test group: ~tp~n",
[Module])}
end;
init_per_group1(backing_queue_v2, Config) ->
ok = rabbit_ct_broker_helpers:rpc(Config, 0,
application, set_env, [rabbit, classic_queue_default_version, 2]),
Config;
init_per_group1(backing_queue_embed_limit_0, Config) ->
ok = rabbit_ct_broker_helpers:rpc(Config, 0,
application, set_env, [rabbit, queue_index_embed_msgs_below, 0]),
Expand Down Expand Up @@ -171,11 +167,6 @@ end_per_group1(backing_queue_tests, Config) ->
rabbit_ct_broker_helpers:rpc(Config, 0,
?MODULE, teardown_backing_queue_test_group, [Config]);
end_per_group1(Group, Config)
when Group =:= backing_queue_v2 ->
ok = rabbit_ct_broker_helpers:rpc(Config, 0,
application, unset_env, [rabbit, classic_queue_default_version]),
Config;
end_per_group1(Group, Config)
when Group =:= backing_queue_embed_limit_0
orelse Group =:= backing_queue_embed_limit_1024 ->
ok = rabbit_ct_broker_helpers:rpc(Config, 0,
Expand Down
5 changes: 1 addition & 4 deletions deps/rabbitmq_mqtt/test/shared_SUITE.erl
Original file line number Diff line number Diff line change
Expand Up @@ -201,11 +201,8 @@ init_per_group(Group, Config0) ->
Config1,
[{rmq_nodes_count, Nodes},
{rmq_nodename_suffix, Suffix}]),
Config3 = rabbit_ct_helpers:merge_app_env(
Config2,
{rabbit, [{classic_queue_default_version, 2}]}),
Config = rabbit_ct_helpers:run_steps(
Config3,
Config2,
rabbit_ct_broker_helpers:setup_steps() ++
rabbit_ct_client_helpers:setup_steps()),
util:maybe_skip_v5(Config).
Expand Down
3 changes: 1 addition & 2 deletions deps/rabbitmq_mqtt/test/v5_SUITE.erl
Original file line number Diff line number Diff line change
Expand Up @@ -169,8 +169,7 @@ init_per_group(Group, Config0) ->
{rmq_nodename_suffix, Suffix}]),
Config2 = rabbit_ct_helpers:merge_app_env(
Config1,
{rabbit, [{classic_queue_default_version, 2},
{quorum_tick_interval, 200}]}),
{rabbit, [{quorum_tick_interval, 200}]}),
Config = rabbit_ct_helpers:run_steps(
Config2,
rabbit_ct_broker_helpers:setup_steps() ++
Expand Down

0 comments on commit 2723dad

Please sign in to comment.