summaryrefslogtreecommitdiff
path: root/test
diff options
context:
space:
mode:
authorAlexey Lebedeff <binarin@gmail.com>2015-10-20 21:17:14 +0300
committerMichael Klishin <mklishin@pivotal.io>2015-10-22 12:16:34 +0300
commit0069732db116c4ffb4a11d6a5311143d4d5d8e35 (patch)
treeda2036cae0d9901820b06d8da52c3e3d13397bbb /test
parent94b2959c061d40bbf379e1cf7adaf4c6a48b01ea (diff)
downloadrabbitmq-server-git-0069732db116c4ffb4a11d6a5311143d4d5d8e35.tar.gz
Add `exclusive` item to `rabbitmqctl list_queues`
In addition to owner_pid, which makes little sense to beginners. References #371
Diffstat (limited to 'test')
-rw-r--r--test/src/rabbit_tests.erl10
1 files changed, 8 insertions, 2 deletions
diff --git a/test/src/rabbit_tests.erl b/test/src/rabbit_tests.erl
index fc6384bfb2..383bc91a5a 100644
--- a/test/src/rabbit_tests.erl
+++ b/test/src/rabbit_tests.erl
@@ -1160,17 +1160,23 @@ test_ha_policy_validation() ->
test_server_status() ->
%% create a few things so there is some useful information to list
{_Writer, Limiter, Ch} = test_channel(),
- [Q, Q2] = [Queue || Name <- [<<"foo">>, <<"bar">>],
+ [Q, Q2] = [Queue || {Name, Owner} <- [{<<"foo">>, none}, {<<"bar">>, self()}],
{new, Queue = #amqqueue{}} <-
[rabbit_amqqueue:declare(
rabbit_misc:r(<<"/">>, queue, Name),
- false, false, [], none)]],
+ false, false, [], Owner)]],
ok = rabbit_amqqueue:basic_consume(
Q, true, Ch, Limiter, false, 0, <<"ctag">>, true, [], undefined),
%% list queues
ok = info_action(list_queues, rabbit_amqqueue:info_keys(), true),
+ %% as we have no way to collect output of info_action/3 call, the only way
+ %% we can test individual queueinfoitems is by directly calling
+ %% rabbit_amqqueue:info/2
+ [{exclusive, false}] = rabbit_amqqueue:info(Q, [exclusive]),
+ [{exclusive, true}] = rabbit_amqqueue:info(Q2, [exclusive]),
+
%% list exchanges
ok = info_action(list_exchanges, rabbit_exchange:info_keys(), true),