diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2014-03-18 16:04:00 +0000 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2014-03-18 16:04:00 +0000 |
| commit | f2698c6b73b0d52b213fafb0d820151e87cf2aba (patch) | |
| tree | 7e4edf06b642099d0c93a6ff24e0b140ce1038c3 | |
| parent | d88b34e6f40c1a03381e677c202f5c33aaf78985 (diff) | |
| download | rabbitmq-server-f2698c6b73b0d52b213fafb0d820151e87cf2aba.tar.gz | |
Don't explode on "rabbitmqctl stop_app ; rabbitmqctl status", and fix tests.
| -rw-r--r-- | src/rabbit.erl | 8 | ||||
| -rw-r--r-- | src/rabbit_tests.erl | 3 |
2 files changed, 8 insertions, 3 deletions
diff --git a/src/rabbit.erl b/src/rabbit.erl index 7a3746ea..503141c2 100644 --- a/src/rabbit.erl +++ b/src/rabbit.erl @@ -426,12 +426,16 @@ alarms() -> [Limit || {{resource_limit, Limit, Node}, _} <- Alarms, Node =:= N]. listeners() -> + Listeners = try + rabbit_networking:active_listeners() + catch + exit:{aborted, _} -> [] + end, [{Protocol, Port, rabbit_misc:ntoa(IP)} || #listener{node = Node, protocol = Protocol, ip_address = IP, - port = Port} <- rabbit_networking:active_listeners(), - Node =:= node()]. + port = Port} <- Listeners, Node =:= node()]. is_running() -> is_running(node()). diff --git a/src/rabbit_tests.erl b/src/rabbit_tests.erl index ad4cd560..53858dd0 100644 --- a/src/rabbit_tests.erl +++ b/src/rabbit_tests.erl @@ -1236,7 +1236,8 @@ test_amqp_connection_refusal(Header) -> find_listener() -> [#listener{host = H, port = P} | _] = - [L || L = #listener{node = N} <- rabbit_networking:active_listeners(), + [L || L = #listener{node = N, protocol = amqp} + <- rabbit_networking:active_listeners(), N =:= node()], {H, P}. |