From 54e9c97134400d82dbbd27aa87d5f3c9a8541962 Mon Sep 17 00:00:00 2001 From: Ayanda Dube Date: Tue, 29 Jul 2025 19:00:38 +0100 Subject: [PATCH 1/2] assert that quorum queues are always durable on initialization --- deps/rabbit/src/rabbit_quorum_queue.erl | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/deps/rabbit/src/rabbit_quorum_queue.erl b/deps/rabbit/src/rabbit_quorum_queue.erl index d068d51bb57d..5e57da8022b3 100644 --- a/deps/rabbit/src/rabbit_quorum_queue.erl +++ b/deps/rabbit/src/rabbit_quorum_queue.erl @@ -261,7 +261,7 @@ declare(Q, _Node) when ?amqqueue_is_quorum(Q) -> start_cluster(Q) -> QName = amqqueue:get_name(Q), - Durable = amqqueue:is_durable(Q), + Durable = true = amqqueue:is_durable(Q), AutoDelete = amqqueue:is_auto_delete(Q), Arguments = amqqueue:get_arguments(Q), Opts = amqqueue:get_options(Q), From 82ab56372ced368a71124424138343960aca01c1 Mon Sep 17 00:00:00 2001 From: Ayanda Dube Date: Tue, 29 Jul 2025 19:13:03 +0100 Subject: [PATCH 2/2] assert that auto-delete is always false for quorum queues on initialization --- deps/rabbit/src/rabbit_quorum_queue.erl | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/deps/rabbit/src/rabbit_quorum_queue.erl b/deps/rabbit/src/rabbit_quorum_queue.erl index 5e57da8022b3..1942b1125f5d 100644 --- a/deps/rabbit/src/rabbit_quorum_queue.erl +++ b/deps/rabbit/src/rabbit_quorum_queue.erl @@ -262,7 +262,7 @@ declare(Q, _Node) when ?amqqueue_is_quorum(Q) -> start_cluster(Q) -> QName = amqqueue:get_name(Q), Durable = true = amqqueue:is_durable(Q), - AutoDelete = amqqueue:is_auto_delete(Q), + AutoDelete = false = amqqueue:is_auto_delete(Q), Arguments = amqqueue:get_arguments(Q), Opts = amqqueue:get_options(Q), ActingUser = maps:get(user, Opts, ?UNKNOWN_USER),