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

Update unit_inbroker suite to support amqqeueue module.

This commit is contained in:
Daniil Fedotov 2019-02-07 17:41:37 -05:00
parent 5cd158b4e3
commit c1c3660c98
1 changed files with 11 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
deps/rabbitmq_federation/test/unit_inbroker_SUITE.erl vendored
View File

@ -143,19 +143,18 @@ remove_credentials(Config) ->
Test(<<"amqps://">>, <<"localhost:5672/%2f">>),
ok.
get_connection_name(_Config) ->
Q = amqqueue:new(rabbit_misc:r(<<"/">>, queue, <<"queue">>),
self(),
false,
false,
none,
[],
undefined,
#{},
classic),
get_connection_name(Config) ->
FeatureFlagsFile = rabbit_ct_broker_helpers:rpc(Config, 0, application, get_env, [rabbit, feature_flags_file, "/tmp/none"]),
application:set_env(rabbit, feature_flags_file, FeatureFlagsFile),
Amqqueue = amqqueue:new(#resource{kind = queue}, none, false, false, none, [], <<"/">>, #{}, classic),
AmqqueueWithPolicy = amqqueue:set_policy(Amqqueue, [{name, <<"my.federation.policy">>}]),
AmqqueueWithEmptyPolicy = amqqueue:set_policy(Amqqueue, []),
<<"Federation link (upstream: my.upstream, policy: my.federation.policy)">> = rabbit_federation_link_util:get_connection_name(
#upstream{name = <<"my.upstream">>},
#upstream_params{x_or_q = amqqueue:set_policy(Q, [{name, <<"my.federation.policy">>}])}
#upstream_params{x_or_q = AmqqueueWithPolicy}
),
<<"Federation link (upstream: my.upstream, policy: my.federation.policy)">> = rabbit_federation_link_util:get_connection_name(
#upstream{name = <<"my.upstream">>},
@ -163,7 +162,7 @@ get_connection_name(_Config) ->
),
<<"Federation link">> = rabbit_federation_link_util:get_connection_name(
#upstream{},
#upstream_params{x_or_q = amqqueue:set_policy(Q, [])}
#upstream_params{x_or_q = AmqqueueWithEmptyPolicy}
),
<<"Federation link">> = rabbit_federation_link_util:get_connection_name(
#upstream{},