summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorMatthew Sackman <matthew@rabbitmq.com>2011-01-20 16:55:07 +0000
committerMatthew Sackman <matthew@rabbitmq.com>2011-01-20 16:55:07 +0000
commit04af35656ad30e621b238d0e1000f26b5f450f00 (patch)
treead0713ffc2e9f584ac9b828682d11f12be37badb
parent1c7ea9f1875eb3cbefab5828932b6aa1b7caf255 (diff)
parent3aff2ac175d681b1b7d68b2a2cf0f12004180fcc (diff)
downloadrabbitmq-server-git-04af35656ad30e621b238d0e1000f26b5f450f00.tar.gz
Merging bug23723 into default
-rw-r--r--src/rabbit_control.erl11
1 files changed, 7 insertions, 4 deletions
diff --git a/src/rabbit_control.erl b/src/rabbit_control.erl
index 78391be2ef..4228ff7fd3 100644
--- a/src/rabbit_control.erl
+++ b/src/rabbit_control.erl
@@ -273,10 +273,13 @@ action(list_consumers, Node, _Args, Opts, Inform) ->
Inform("Listing consumers", []),
VHostArg = list_to_binary(proplists:get_value(?VHOST_OPT, Opts)),
InfoKeys = [queue_name, channel_pid, consumer_tag, ack_required],
- display_info_list(
- [lists:zip(InfoKeys, tuple_to_list(X)) ||
- X <- rpc_call(Node, rabbit_amqqueue, consumers_all, [VHostArg])],
- InfoKeys);
+ case rpc_call(Node, rabbit_amqqueue, consumers_all, [VHostArg]) of
+ L when is_list(L) -> display_info_list(
+ [lists:zip(InfoKeys, tuple_to_list(X)) ||
+ X <- L],
+ InfoKeys);
+ Other -> Other
+ end;
action(set_permissions, Node, [Username, CPerm, WPerm, RPerm], Opts, Inform) ->
VHost = proplists:get_value(?VHOST_OPT, Opts),