Changed schema logic

deps/rabbit/priv/schema/rabbit.schema

@@ -2512,7 +2512,19 @@ end}.
 }.
 
 {mapping, "default_queue_type", "rabbit.default_queue_type", [
-  {datatype, {enum, [quorum, classic, stream]}}]}.
+    {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}.
+
 
 
 %%

deps/rabbit/src/rabbit_queue_type.erl

@@ -275,15 +275,9 @@ feature_flag_name(_) ->
     undefined.
 
 default() ->
-    case rabbit_misc:get_env(rabbit,
+    rabbit_misc:get_env(rabbit,
-                             default_queue_type,
+                        default_queue_type,
-                             classic)
+                        rabbit_classic_queue).
-    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) ->