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

Add a test for DQT upon vhost creation

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

28
deps/rabbit/test/vhost_SUITE.erl vendored
View File

@ -27,6 +27,7 @@ all() ->
groups() -> groups() ->
ClusterSize1Tests = [ ClusterSize1Tests = [
vhost_is_created_with_default_limits, vhost_is_created_with_default_limits,
vhost_is_created_with_default_queue_type,
vhost_is_created_with_operator_policies, vhost_is_created_with_operator_policies,
vhost_is_created_with_default_user, vhost_is_created_with_default_user,
single_node_vhost_deletion_forces_connection_closure, single_node_vhost_deletion_forces_connection_closure,
@ -467,6 +468,33 @@ vhost_is_created_with_default_limits(Config) ->
application, unset_env, [rabbit, default_limits]) application, unset_env, [rabbit, default_limits])
end. end.
vhost_is_created_with_default_queue_type(Config) ->
VHost = atom_to_binary(?FUNCTION_NAME),
QName = atom_to_binary(?FUNCTION_NAME),
?assertEqual(ok, rabbit_ct_broker_helpers:rpc(Config, 0,
application, set_env, [rabbit, default_queue_type, rabbit_quorum_queue])),
try
?assertEqual(ok, rabbit_ct_broker_helpers:add_vhost(Config, VHost)),
rabbit_ct_broker_helpers:set_full_permissions(Config, <<"guest">>, VHost),
?assertEqual(<<"quorum">>, rabbit_ct_broker_helpers:rpc(Config, 0,
rabbit_vhost, default_queue_type, [VHost])),
V = rabbit_ct_broker_helpers:rpc(Config, 0, rabbit_db_vhost, get, [VHost]),
ct:pal("Vhost metadata: ~p", [V]),
?assertEqual(<<"quorum">>, maps:get(default_queue_type, vhost:get_metadata(V))),
Conn = rabbit_ct_client_helpers:open_unmanaged_connection(Config, 0, VHost),
{ok, Chan} = amqp_connection:open_channel(Conn),
amqp_channel:call(Chan, #'queue.declare'{queue = QName, durable = true}),
QNameRes = rabbit_misc:r(VHost, queue, QName),
{ok, Q} = rabbit_ct_broker_helpers:rpc(Config, 0, rabbit_amqqueue, lookup, [QNameRes]),
?assertMatch(rabbit_quorum_queue, amqqueue:get_type(Q)),
close_connections([Conn])
after
rabbit_ct_broker_helpers:rpc(
Config, 0,
application, unset_env, [rabbit, default_queue_type])
end.
vhost_is_created_with_operator_policies(Config) -> vhost_is_created_with_operator_policies(Config) ->
VHost = <<"vhost1">>, VHost = <<"vhost1">>,
PolicyName = <<"default-operator-policy">>, PolicyName = <<"default-operator-policy">>,