Skip to content

Commit b49b9a8

Browse files
Merge pull request #11163 from SimonUnge/global_default_queue_type
Added global default queue type config
2 parents 1ecaaad + ad69f5b commit b49b9a8

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
@@ -275,7 +275,9 @@ feature_flag_name(_) ->
275275
undefined.
276276

277277
default() ->
278-
rabbit_classic_queue.
278+
rabbit_misc:get_env(rabbit,
279+
default_queue_type,
280+
rabbit_classic_queue).
279281

280282
-spec to_binary(module()) -> binary().
281283
to_binary(rabbit_classic_queue) ->

0 commit comments

Comments
 (0)