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

tests sanity

This commit is contained in:
Daniil Fedotov 2016-03-18 10:03:23 +00:00
parent 9f5f238ca4
commit 81b4fcfb18
1 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
deps/rabbitmq_stomp/test/src/rabbit_stomp_amqqueue_test.erl vendored
View File

@ -58,17 +58,18 @@ run_test(TestFun, Version) ->
test_publish_no_dest_error(Channel, Client, Version) -> test_publish_no_dest_error(Channel, Client, Version) ->
rabbit_stomp_client:send( rabbit_stomp_client:send(
Client, "SEND", [{"destination", "/amq/exchange/nonexist"}], ["hello"]), Client, "SEND", [{"destination", "/exchange/non-existent"}], ["hello"]),
{ok, _Client1, Hdrs, _} = stomp_receive(Client, "ERROR"), {ok, _Client1, Hdrs, _} = stomp_receive(Client, "ERROR"),
"Unknown destination" = proplists:get_value("message", Hdrs), "not_found" = proplists:get_value("message", Hdrs),
ok. ok.
test_publish_unauthorized_error(Channel, _Client, Version) -> test_publish_unauthorized_error(Channel, _Client, Version) ->
#'queue.declare_ok'{} = #'queue.declare_ok'{} =
amqp_channel:call(Channel, #'queue.declare'{queue = <<"RestrictedQueue">>, amqp_channel:call(Channel, #'queue.declare'{queue = <<"RestrictedQueue">>,
auto_delete = true}), auto_delete = true}),
os:cmd("../rabbit/scripts/rabbitmqctl add_user foo foo"), rabbit_auth_backend_internal:add_user(<<"foo">>, <<"foo">>),
os:cmd("../rabbit/scripts/rabbitmqctl set_permissions foo foo foo foo"), rabbit_auth_backend_internal:set_permissions(
<<"foo">>, <<"/">>, <<"foo">>, <<"foo">>, <<"foo">>),
{ok, ClientFoo} = rabbit_stomp_client:connect(Version, "foo", "foo"), {ok, ClientFoo} = rabbit_stomp_client:connect(Version, "foo", "foo"),
try try
rabbit_stomp_client:send( rabbit_stomp_client:send(