Skip to content

Commit 4d34d39

Browse files
Merge pull request #11164 from rabbitmq/mergify/bp/v3.13.x/pr-11163
Added global default queue type config (backport #11163)
2 parents ee8c688 + d403b40 commit 4d34d39

File tree

2 files changed

+19
-1
lines changed

2 files changed

+19
-1
lines changed

deps/rabbit/priv/schema/rabbit.schema

Lines changed: 16 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -2511,6 +2511,22 @@ end}.
25112511
end
25122512
}.
25132513

2514+
{mapping, "default_queue_type", "rabbit.default_queue_type", [
2515+
{datatype, atom}
2516+
]}.
2517+
2518+
{translation, "rabbit.default_queue_type",
2519+
fun(Conf) ->
2520+
case cuttlefish:conf_get("default_queue_type", Conf, rabbit_classic_queue) of
2521+
classic -> rabbit_classic_queue;
2522+
quorum -> rabbit_quorum_queue;
2523+
stream -> rabbit_stream_queue;
2524+
Module -> Module
2525+
end
2526+
end}.
2527+
2528+
2529+
25142530
%%
25152531
%% Backing queue version
25162532
%%

deps/rabbit/src/rabbit_queue_type.erl

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -260,7 +260,9 @@ feature_flag_name(_) ->
260260
undefined.
261261

262262
default() ->
263-
rabbit_classic_queue.
263+
rabbit_misc:get_env(rabbit,
264+
default_queue_type,
265+
rabbit_classic_queue).
264266

265267
%% is a specific queue type implementation enabled
266268
-spec is_enabled(module()) -> boolean().

0 commit comments

Comments
 (0)