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

Merge pull request #14626 from rabbitmq/mergify/bp/v4.2.x/pr-14624 

Allow configuring whether queue types are enabled (backport #14624)
This commit is contained in:
Michael Klishin 2025-09-26 16:52:03 -04:00 committed by GitHub
parent c147aea590 35294beb70
commit 23f53ed267
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
4 changed files with 15 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
deps/rabbit/priv/schema/rabbit.schema vendored
View File

@ -2629,6 +2629,18 @@ end}.
{datatype, {enum, [true, false]}}
]}.
%% Enable queue types
{mapping, "queue_types.classic.enabled", "rabbit.classic_queues_enabled", [
{datatype, {enum, [true, false]}}
]}.
{mapping, "queue_types.stream.enabled", "rabbit.stream_queues_enabled", [
{datatype, {enum, [true, false]}}
]}.
{mapping, "queue_types.quorum.enabled", "rabbit.quorum_queues_enabled", [
{datatype, {enum, [true, false]}}
]}.
%%
%% Backing queue version
%%

2
deps/rabbit/src/rabbit_classic_queue.erl vendored
View File

@ -126,7 +126,7 @@ validate_policy(Args) ->
end.
-spec is_enabled() -> boolean().
is_enabled() -> true.
is_enabled() -> application:get_env(rabbit, classic_queues_enabled, true).
-spec is_compatible(boolean(), boolean(), boolean()) -> boolean().
is_compatible(_, _, _) ->

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

@ -201,7 +201,7 @@ merge_policy_value(<<"target-group-size">>, Val, OpVal) ->
%%----------- rabbit_queue_type ---------------------------------------------
-spec is_enabled() -> boolean().
is_enabled() -> true.
is_enabled() -> application:get_env(rabbit, quorum_queues_enabled, true).
-spec is_compatible(boolean(), boolean(), boolean()) -> boolean().
is_compatible(_Durable = true,

2
deps/rabbit/src/rabbit_stream_queue.erl vendored
View File

@ -133,7 +133,7 @@
-type client() :: #stream_client{}.
-spec is_enabled() -> boolean().
is_enabled() -> true.
is_enabled() -> application:get_env(rabbit, stream_queues_enabled, true).
-spec is_compatible(boolean(), boolean(), boolean()) -> boolean().
is_compatible(_Durable = true,