summaryrefslogtreecommitdiff
path: root/test
diff options
context:
space:
mode:
authorAlvaro Videla <videlalvaro@gmail.com>2015-11-02 22:08:27 +0100
committerAlvaro Videla <videlalvaro@gmail.com>2015-11-02 22:08:27 +0100
commitbbc58be11ef8d2b983840abe6d276777e8a83e84 (patch)
tree715adb088a3068173aac5e578254aa18937fc3f8 /test
parent7112c6896d8dded26bade8d51a27a850b299bfc7 (diff)
downloadrabbitmq-server-git-bbc58be11ef8d2b983840abe6d276777e8a83e84.tar.gz
removes rabbit_ctl_timeout_tests.erl from rabbit repo
Diffstat (limited to 'test')
-rw-r--r--test/src/rabbit_ctl_timeout_tests.erl130
1 files changed, 0 insertions, 130 deletions
diff --git a/test/src/rabbit_ctl_timeout_tests.erl b/test/src/rabbit_ctl_timeout_tests.erl
deleted file mode 100644
index 33e51d72e1..0000000000
--- a/test/src/rabbit_ctl_timeout_tests.erl
+++ /dev/null
@@ -1,130 +0,0 @@
-%% The contents of this file are subject to the Mozilla Public License
-%% Version 1.1 (the "License"); you may not use this file except in
-%% compliance with the License. You may obtain a copy of the License
-%% at http://www.mozilla.org/MPL/
-%%
-%% Software distributed under the License is distributed on an "AS IS"
-%% basis, WITHOUT WARRANTY OF ANY KIND, either express or implied. See
-%% the License for the specific language governing rights and
-%% limitations under the License.
-%%
-%% The Original Code is RabbitMQ.
-%%
-%% The Initial Developer of the Original Code is GoPivotal, Inc.
-%% Copyright (c) 2007-2015 Pivotal Software, Inc. All rights reserved.
-%%
--module(rabbit_ctl_timeout_tests).
-
--compile([export_all]).
-
--export([all_tests/0]).
-
--import(rabbit_tests,[control_action/2, control_action/3, control_action/4,
- control_action/5, control_action_opts/1, test_channel/0,
- find_listener/0, info_action/4]).
-
--include("rabbit.hrl").
-
--define(TIMEOUT_LIST_OPS_PASS, 1000).
-
-all_tests() ->
- passed = test_list_operations_timeout_pass(),
- passed.
-
-test_list_operations_timeout_pass() ->
- %% create a few things so there is some useful information to list
- {_Writer, Limiter, Ch} = test_channel(),
- [Q, Q2] = [Queue || Name <- [<<"foo">>, <<"bar">>],
- {new, Queue = #amqqueue{}} <-
- [rabbit_amqqueue:declare(
- rabbit_misc:r(<<"/">>, queue, Name),
- false, false, [], none)]],
- ok = rabbit_amqqueue:basic_consume(
- Q, true, Ch, Limiter, false, 0, <<"ctag">>, true, [], undefined),
-
- %% list users
- ok = control_action(add_user, ["foo", "bar"]),
- {error, {user_already_exists, _}} =
- control_action(add_user, ["foo", "bar"]),
- ok = control_action(list_users, [], ?TIMEOUT_LIST_OPS_PASS),
-
- %% list parameters
- ok = rabbit_runtime_parameters_test:register(),
- ok = control_action(set_parameter, ["test", "good", "123"]),
- ok = control_action(list_parameters, [], ?TIMEOUT_LIST_OPS_PASS),
- ok = control_action(clear_parameter, ["test", "good"]),
- rabbit_runtime_parameters_test:unregister(),
-
- %% list vhosts
- ok = control_action(add_vhost, ["/testhost"]),
- {error, {vhost_already_exists, _}} =
- control_action(add_vhost, ["/testhost"]),
- ok = control_action(list_vhosts, [], ?TIMEOUT_LIST_OPS_PASS),
-
- %% list permissions
- ok = control_action(set_permissions, ["foo", ".*", ".*", ".*"],
- [{"-p", "/testhost"}]),
- ok = control_action(list_permissions, [], [{"-p", "/testhost"}],
- ?TIMEOUT_LIST_OPS_PASS),
-
- %% list user permissions
- ok = control_action(list_user_permissions, ["foo"],
- ?TIMEOUT_LIST_OPS_PASS),
-
- %% list policies
- ok = control_action_opts(["set_policy", "name", ".*",
- "{\"ha-mode\":\"all\"}"]),
- ok = control_action(list_policies, [], ?TIMEOUT_LIST_OPS_PASS),
- ok = control_action(clear_policy, ["name"]),
-
- %% list queues
- ok = info_action(list_queues, rabbit_amqqueue:info_keys(), false,
- ?TIMEOUT_LIST_OPS_PASS),
-
- %% list exchanges
- ok = info_action(list_exchanges, rabbit_exchange:info_keys(), true,
- ?TIMEOUT_LIST_OPS_PASS),
-
- %% list bindings
- ok = info_action(list_bindings, rabbit_binding:info_keys(), true,
- ?TIMEOUT_LIST_OPS_PASS),
-
- %% list connections
- {H, P} = find_listener(),
- {ok, C} = gen_tcp:connect(H, P, [binary, {active, false}]),
- gen_tcp:send(C, <<"AMQP", 0, 0, 9, 1>>),
- {ok, <<1,0,0>>} = gen_tcp:recv(C, 3, 100),
- ok = info_action(list_connections,
- rabbit_networking:connection_info_keys(),
- false,
- ?TIMEOUT_LIST_OPS_PASS),
-
- %% list consumers
- ok = info_action(list_consumers, rabbit_amqqueue:consumer_info_keys(),
- false, ?TIMEOUT_LIST_OPS_PASS),
-
- %% list channels
- ok = info_action(list_channels, rabbit_channel:info_keys(), false,
- ?TIMEOUT_LIST_OPS_PASS),
-
- %% do some cleaning up
- ok = control_action(delete_user, ["foo"]),
- {error, {no_such_user, _}} =
- control_action(delete_user, ["foo"]),
-
- ok = control_action(delete_vhost, ["/testhost"]),
- {error, {no_such_vhost, _}} =
- control_action(delete_vhost, ["/testhost"]),
-
- %% close_connection
- [ConnPid] = rabbit_networking:connections(),
- ok = control_action(close_connection, [rabbit_misc:pid_to_string(ConnPid),
- "go away"]),
-
- %% cleanup queues
- [{ok, _} = rabbit_amqqueue:delete(QR, false, false) || QR <- [Q, Q2]],
-
- unlink(Ch),
- ok = rabbit_channel:shutdown(Ch),
-
- passed.