Skip to content

Commit 9bd11b4

Browse files
committed
Set the DQT in rabbit_vhost:do_add
1 parent 9d0f01b commit 9bd11b4

File tree

1 file changed

+9
-2
lines changed

1 file changed

+9
-2
lines changed

deps/rabbit/src/rabbit_vhost.erl

+9-2
Original file line numberDiff line numberDiff line change
@@ -178,7 +178,6 @@ add(VHost, ActingUser) ->
178178
rabbit_types:ok_or_error(any()).
179179
add(Name, Description, Tags, ActingUser) ->
180180
add(Name, #{description => Description,
181-
default_queue_type => rabbit_queue_type:default_alias(),
182181
tags => Tags}, ActingUser).
183182

184183
-spec add(vhost:name(), vhost:metadata(), rabbit_types:username()) ->
@@ -190,8 +189,16 @@ add(Name, Metadata, ActingUser) ->
190189
catch(do_add(Name, Metadata, ActingUser))
191190
end.
192191

193-
do_add(Name, Metadata, ActingUser) ->
192+
do_add(Name, Metadata0, ActingUser) ->
194193
ok = is_over_vhost_limit(Name),
194+
195+
Metadata = case maps:is_key(default_queue_type, Metadata0) of
196+
true ->
197+
Metadata0;
198+
false ->
199+
Metadata0#{default_queue_type => rabbit_queue_type:default_alias()}
200+
end,
201+
195202
Description = maps:get(description, Metadata, undefined),
196203
Tags = maps:get(tags, Metadata, []),
197204

0 commit comments

Comments
 (0)