Added global default queue type config

This commit is contained in:
Simon Unge 2024-05-03 18:41:59 +00:00
parent 1ecaaadb32
commit 2e2bbaff33
2 changed files with 13 additions and 1 deletions

View File

@ -2511,6 +2511,10 @@ end}.
end
}.
{mapping, "default_queue_type", "rabbit.default_queue_type", [
{datatype, {enum, [quorum, classic, stream]}}]}.
%%
%% Backing queue version
%%

View File

@ -275,7 +275,15 @@ feature_flag_name(_) ->
undefined.
default() ->
rabbit_classic_queue.
case rabbit_misc:get_env(rabbit,
default_queue_type,
classic)
of
quorum -> rabbit_quorum_queue;
classic -> rabbit_classic_queue;
stream -> rabbit_stream_queue;
_ -> rabbit_classic_queue
end.
-spec to_binary(module()) -> binary().
to_binary(rabbit_classic_queue) ->