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

Merge branch 'main' into rabbitmq-server-8836

This commit is contained in:
Michael Klishin 2023-07-13 02:26:41 +04:00 committed by GitHub
parent 39247eafd6 e9a785d89c
commit b8105de827
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 10 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
deps/rabbitmq_stomp/test/topic_SUITE.erl vendored
View File

@ -137,18 +137,25 @@ subscribe_topic_authorisation(Config) ->
change_default_topic_exchange(Config) ->
Channel = ?config(amqp_channel, Config),
ClientFoo = ?config(client_foo, Config),
Version = ?config(version, Config),
StompPort = rabbit_ct_broker_helpers:get_node_config(Config, 0, tcp_port_stomp),
Ex = <<"my-topic-exchange">>,
ok = rabbit_ct_broker_helpers:rpc(Config, 0, application, set_env, [rabbitmq_stomp, default_topic_exchange, Ex]),
{ok, ClientFoo} = rabbit_stomp_client:connect(Version, StompPort),
AuthorisedTopic = "/topic/user.AuthorisedTopic",
Declare = #'exchange.declare'{exchange = Ex, type = <<"topic">>},
#'exchange.declare_ok'{} = amqp_channel:call(Channel, Declare),
ok = rabbit_ct_broker_helpers:rpc(Config, 0, application, set_env, [rabbitmq_stomp, default_topic_exchange, Ex]),
0 = length(rabbit_ct_broker_helpers:rpc(Config, 0, rabbit_binding, list_for_source, [#resource{virtual_host= <<"/">>, kind = exchange, name = Ex}])),
rabbit_stomp_client:send(
ClientFoo, "SUBSCRIBE", [{"destination", AuthorisedTopic}]),
timer:sleep(500),
1 = length(rabbit_ct_broker_helpers:rpc(Config, 0, rabbit_binding, list_for_source, [#resource{virtual_host= <<"/">>, kind = exchange, name = Ex}])),
rabbit_stomp_client:send(
ClientFoo, "SEND", [{"destination", AuthorisedTopic}], ["ohai there"]),
@ -158,6 +165,7 @@ change_default_topic_exchange(Config) ->
Delete = #'exchange.delete'{exchange = Ex},
#'exchange.delete_ok'{} = amqp_channel:call(Channel, Delete),
ok = rabbit_ct_broker_helpers:rpc(Config, 0, application, unset_env, [rabbitmq_stomp, default_topic_exchange]),
rabbit_stomp_client:disconnect(ClientFoo),
ok.