diff --git a/deps/rabbit/priv/schema/rabbit.schema b/deps/rabbit/priv/schema/rabbit.schema index d18f643d56d7..097b89c65100 100644 --- a/deps/rabbit/priv/schema/rabbit.schema +++ b/deps/rabbit/priv/schema/rabbit.schema @@ -2511,6 +2511,22 @@ end}. end }. +{mapping, "default_queue_type", "rabbit.default_queue_type", [ + {datatype, atom} +]}. + +{translation, "rabbit.default_queue_type", +fun(Conf) -> + case cuttlefish:conf_get("default_queue_type", Conf, rabbit_classic_queue) of + classic -> rabbit_classic_queue; + quorum -> rabbit_quorum_queue; + stream -> rabbit_stream_queue; + Module -> Module + end +end}. + + + %% %% Backing queue version %% diff --git a/deps/rabbit/src/rabbit_queue_type.erl b/deps/rabbit/src/rabbit_queue_type.erl index 4443372458c1..61f67f738c48 100644 --- a/deps/rabbit/src/rabbit_queue_type.erl +++ b/deps/rabbit/src/rabbit_queue_type.erl @@ -260,7 +260,9 @@ feature_flag_name(_) -> undefined. default() -> - rabbit_classic_queue. + rabbit_misc:get_env(rabbit, + default_queue_type, + rabbit_classic_queue). %% is a specific queue type implementation enabled -spec is_enabled(module()) -> boolean().