summaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
authorSimon MacMullen <simon@rabbitmq.com>2010-06-25 14:29:41 +0100
committerSimon MacMullen <simon@rabbitmq.com>2010-06-25 14:29:41 +0100
commitd67e8c446106168fb387663ac7ff58a5f790b09a (patch)
tree939aae576b600612f87f8d4a77bb769ae8fe9470 /src
parentecf4739616d100401bbe7738dbf18a689b383303 (diff)
downloadrabbitmq-server-git-d67e8c446106168fb387663ac7ff58a5f790b09a.tar.gz
Show protocol in rabbitmqctl list_connections. I *think* this is interesting enough to put in the default list of info items.
Diffstat (limited to 'src')
-rw-r--r--src/rabbit_control.erl3
-rw-r--r--src/rabbit_reader.erl4
2 files changed, 5 insertions, 2 deletions
diff --git a/src/rabbit_control.erl b/src/rabbit_control.erl
index 323d4d2fd1..042f82844f 100644
--- a/src/rabbit_control.erl
+++ b/src/rabbit_control.erl
@@ -240,7 +240,8 @@ action(list_bindings, Node, Args, Inform) ->
action(list_connections, Node, Args, Inform) ->
Inform("Listing connections", []),
- ArgAtoms = default_if_empty(Args, [user, peer_address, peer_port, state]),
+ ArgAtoms = default_if_empty(Args, [user, peer_address, peer_port, state,
+ protocol]),
display_info_list(rpc_call(Node, rabbit_networking, connection_info_all,
[ArgAtoms]),
ArgAtoms);
diff --git a/src/rabbit_reader.erl b/src/rabbit_reader.erl
index 1dab344ee9..eba738f3f7 100644
--- a/src/rabbit_reader.erl
+++ b/src/rabbit_reader.erl
@@ -61,7 +61,7 @@
queue_collector}).
-define(INFO_KEYS,
- [pid, address, port, peer_address, peer_port,
+ [pid, address, port, peer_address, peer_port, protocol,
recv_oct, recv_cnt, send_oct, send_cnt, send_pend,
state, channels, user, vhost, timeout, frame_max, client_properties]).
@@ -727,6 +727,8 @@ i(peer_address, #v1{sock = Sock}) ->
i(peer_port, #v1{sock = Sock}) ->
{ok, {_, P}} = rabbit_net:peername(Sock),
P;
+i(protocol, #v1{connection = #connection{protocol = Protocol}}) ->
+ Protocol;
i(SockStat, #v1{sock = Sock}) when SockStat =:= recv_oct;
SockStat =:= recv_cnt;
SockStat =:= send_oct;