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

Formatting

This commit is contained in:
Michael Klishin 2017-01-03 15:17:52 +08:00
parent aa1bf987c8
commit d77496c9e2
1 changed files with 7 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
deps/rabbitmq_auth_backend_ldap/test/system_SUITE.erl vendored
View File

@ -405,14 +405,15 @@ topic_authorisation_ldap_only(Config) ->
test_publish(Person, Exchange, RoutingKey, ExpectedResult) ->
{ok, Connection} = amqp_connection:start(Person),
{ok, Channel} = amqp_connection:open_channel(Connection),
ActualResult = try
Publish = #'basic.publish'{exchange = Exchange, routing_key = RoutingKey},
amqp_channel:cast(Channel, Publish, #amqp_msg{payload = <<"foobar">>}),
amqp_channel:call(Channel, #'basic.qos'{prefetch_count = 0}),
ok
ActualResult =
try
Publish = #'basic.publish'{exchange = Exchange, routing_key = RoutingKey},
amqp_channel:cast(Channel, Publish, #amqp_msg{payload = <<"foobar">>}),
amqp_channel:call(Channel, #'basic.qos'{prefetch_count = 0}),
ok
catch exit:_ -> fail
after
amqp_connection:close(Connection)
amqp_connection:close(Connection)
end,
ExpectedResult = ActualResult.