diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2014-03-11 16:16:35 +0000 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2014-03-11 16:16:35 +0000 |
| commit | 7df4645efca85bb3f04b5586eef37d9ea3a4579d (patch) | |
| tree | 29cdcd2b6633c774561116d20a9ea528b433f9e8 /src | |
| parent | 442cc36f9f76d73f5af8e5c33a223fa8648521b0 (diff) | |
| download | rabbitmq-server-git-7df4645efca85bb3f04b5586eef37d9ea3a4579d.tar.gz | |
Show the distribution port as a "protocol" in management.
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_networking.erl | 7 |
1 files changed, 7 insertions, 0 deletions
diff --git a/src/rabbit_networking.erl b/src/rabbit_networking.erl index 42438790c0..112b737562 100644 --- a/src/rabbit_networking.erl +++ b/src/rabbit_networking.erl @@ -120,6 +120,7 @@ %%---------------------------------------------------------------------------- boot() -> + ok = record_distribution_listener(), ok = start(), ok = boot_tcp(), ok = boot_ssl(). @@ -275,6 +276,12 @@ tcp_listener_stopped(Protocol, IPAddress, Port) -> ip_address = IPAddress, port = Port}). +record_distribution_listener() -> + {ok, Names} = net_adm:names(), + {Name, _} = rabbit_nodes:parts(node()), + [Port] = [P || {N, P} <- Names, N =:= Name], + tcp_listener_started('erlang-clustering', {0,0,0,0,0,0,0,0}, Port). + active_listeners() -> rabbit_misc:dirty_read_all(rabbit_listener). |