root
/
rabbitmq-server
mirror of https://github.com/rabbitmq/rabbitmq-server.git
1
0
Fork 0
Code Issues Actions 7 Packages Projects Releases Wiki Activity

Set the DQT in rabbit_vhost:do_add

This commit is contained in:
Michal Kuratczyk 2025-05-02 13:55:54 +02:00
parent 9d0f01b45b
commit 9bd11b449f
No known key found for this signature in database
1 changed files with 9 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
deps/rabbit/src/rabbit_vhost.erl vendored
View File

@ -178,7 +178,6 @@ add(VHost, ActingUser) ->
rabbit_types:ok_or_error(any()). rabbit_types:ok_or_error(any()).
add(Name, Description, Tags, ActingUser) -> add(Name, Description, Tags, ActingUser) ->
add(Name, #{description => Description, add(Name, #{description => Description,
default_queue_type => rabbit_queue_type:default_alias(),
tags => Tags}, ActingUser). tags => Tags}, ActingUser).
-spec add(vhost:name(), vhost:metadata(), rabbit_types:username()) -> -spec add(vhost:name(), vhost:metadata(), rabbit_types:username()) ->
@ -190,8 +189,16 @@ add(Name, Metadata, ActingUser) ->
catch(do_add(Name, Metadata, ActingUser)) catch(do_add(Name, Metadata, ActingUser))
end. end.
do_add(Name, Metadata, ActingUser) -> do_add(Name, Metadata0, ActingUser) ->
ok = is_over_vhost_limit(Name), ok = is_over_vhost_limit(Name),
Metadata = case maps:is_key(default_queue_type, Metadata0) of
true ->
Metadata0;
false ->
Metadata0#{default_queue_type => rabbit_queue_type:default_alias()}
end,
Description = maps:get(description, Metadata, undefined), Description = maps:get(description, Metadata, undefined),
Tags = maps:get(tags, Metadata, []), Tags = maps:get(tags, Metadata, []),