Skip to content

Commit 4932d2e

Browse files
mkuratczykmergify[bot]
authored andcommitted
vhost inherits DQT from node
Rather than injecting node-level DQT when exporting definitions, inject it into vhost's metadata when a vhost is created. (cherry picked from commit 3c95bf3)
1 parent 09b31f6 commit 4932d2e

File tree

3 files changed

+4
-6
lines changed

3 files changed

+4
-6
lines changed

deps/rabbit/src/rabbit_vhost.erl

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -146,6 +146,7 @@ add(VHost, ActingUser) ->
146146
rabbit_types:ok_or_error(any()).
147147
add(Name, Description, Tags, ActingUser) ->
148148
add(Name, #{description => Description,
149+
default_queue_type => rabbit_queue_type:default_alias(),
149150
tags => Tags}, ActingUser).
150151

151152
-spec add(vhost:name(), vhost:metadata(), rabbit_types:username()) ->

deps/rabbit/src/vhost.erl

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -215,7 +215,8 @@ disable_protection_from_deletion(VHost) ->
215215
-spec new_metadata(binary(), [atom()], rabbit_queue_type:queue_type() | 'undefined') -> metadata().
216216
new_metadata(Description, Tags, undefined) ->
217217
#{description => Description,
218-
tags => Tags};
218+
default_queue_type => rabbit_queue_type:default_alias(),
219+
tags => Tags};
219220
new_metadata(Description, Tags, DefaultQueueType) ->
220221
#{description => Description,
221222
tags => Tags,

deps/rabbitmq_management/src/rabbit_mgmt_wm_definitions.erl

Lines changed: 1 addition & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -132,10 +132,7 @@ vhost_definitions(ReqData, VHostName, Context) ->
132132
ProductName = rabbit:product_name(),
133133
ProductVersion = rabbit:product_version(),
134134

135-
DQT = rabbit_queue_type:short_alias_of(rabbit_vhost:default_queue_type(VHostName)),
136-
%% note: the type changes to a map
137-
VHost1 = rabbit_queue_type:inject_dqt(VHost),
138-
Metadata = maps:get(metadata, VHost1),
135+
Metadata = vhost:get_metadata(VHost),
139136

140137
TopLevelDefsAndMetadata = [
141138
{rabbit_version, rabbit_data_coercion:to_binary(Vsn)},
@@ -147,7 +144,6 @@ vhost_definitions(ReqData, VHostName, Context) ->
147144
{explanation, rabbit_data_coercion:to_binary(io_lib:format("Definitions of virtual host '~ts'", [VHostName]))},
148145
{metadata, Metadata},
149146
{description, vhost:get_description(VHost)},
150-
{default_queue_type, DQT},
151147
{limits, vhost:get_limits(VHost)}
152148
],
153149
Result = TopLevelDefsAndMetadata ++ retain_whitelisted(Contents),

0 commit comments

Comments
 (0)