diff options
| -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 7a3746ea1a..503141c26a 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 ad4cd56098..53858dd0bb 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}. |