summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--src/rabbit_variable_queue.erl4
-rw-r--r--test/channel_operation_timeout_test_queue.erl4
2 files changed, 6 insertions, 2 deletions
diff --git a/src/rabbit_variable_queue.erl b/src/rabbit_variable_queue.erl
index 43e0d30a4e..c0a2adbc67 100644
--- a/src/rabbit_variable_queue.erl
+++ b/src/rabbit_variable_queue.erl
@@ -482,7 +482,9 @@ start(DurableQueues) ->
end,
{QNames, maps:put(VHost, [Ref|Refs], VhostRefs)}
end
- end),
+ end,
+ {DurableQueues, #{}},
+ AllTerms),
start_msg_store(VhostRefs, StartFunState),
{ok, AllTerms}.
diff --git a/test/channel_operation_timeout_test_queue.erl b/test/channel_operation_timeout_test_queue.erl
index 5a41eb86bf..124fda47b1 100644
--- a/test/channel_operation_timeout_test_queue.erl
+++ b/test/channel_operation_timeout_test_queue.erl
@@ -232,7 +232,9 @@ start(DurableQueues) ->
end,
{QNames, maps:put(VHost, [Ref|Refs], VhostRefs)}
end
- end),
+ end,
+ {DurableQueues, #{}},
+ AllTerms),
start_msg_store(VhostRefs, StartFunState),
{ok, AllTerms}.