From 2e2bbaff33dc3fd5d53bdbbd9cf63d9079f6601d Mon Sep 17 00:00:00 2001
From: Simon Unge <simunge@amazon.com>
Date: Fri, 3 May 2024 18:41:59 +0000
Subject: [PATCH] Added global default queue type config

---
 deps/rabbit/priv/schema/rabbit.schema |  4 ++++
 deps/rabbit/src/rabbit_queue_type.erl | 10 +++++++++-
 2 files changed, 13 insertions(+), 1 deletion(-)

diff --git a/deps/rabbit/priv/schema/rabbit.schema b/deps/rabbit/priv/schema/rabbit.schema
index 87fe8b47e7..4b6c623c7e 100644
--- 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
index bb686dc0db..b12731cc19 100644
--- 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) ->