Added global default queue type config

rabbitmq · May 3, 2024 · 2e2bbaf · 2e2bbaf
1 parent 1ecaaad
commit 2e2bbaf
Show file tree

Hide file tree

Showing 2 changed files with 13 additions and 1 deletion.
diff --git a/deps/rabbit/priv/schema/rabbit.schema b/deps/rabbit/priv/schema/rabbit.schema
@@ -2511,6 +2511,10 @@ end}.
   end
 }.
 
+{mapping, "default_queue_type", "rabbit.default_queue_type", [
+  {datatype, {enum, [quorum, classic, stream]}}]}.
+
+
 %%
 %% Backing queue version
 %%

diff --git a/deps/rabbit/src/rabbit_queue_type.erl b/deps/rabbit/src/rabbit_queue_type.erl
@@ -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) ->
-Original file line number
+Diff line change
@@ Expand Up / @@ -2511,6 +2511,10 @@ end}. @@
       end
     }.
+    {mapping, "default_queue_type", "rabbit.default_queue_type", [
+      {datatype, {enum, [quorum, classic, stream]}}]}.
     %%
     %% Backing queue version
     %%
@@ Expand Down @@