diff options
| author | Ayanda Dube <ayanda.dube@erlang-solutions.com> | 2015-10-16 01:53:39 +0100 |
|---|---|---|
| committer | Ayanda Dube <ayanda.dube@erlang-solutions.com> | 2015-10-16 01:53:39 +0100 |
| commit | a6ceef958599f1c539f92da7bda7f96cb54a8ca4 (patch) | |
| tree | e1835dcebf016db3be9ae5e04c833f91bb024ac9 | |
| parent | 20396c64ca74caa9696ea268a9cb1b991b08d652 (diff) | |
| download | rabbitmq-server-git-a6ceef958599f1c539f92da7bda7f96cb54a8ca4.tar.gz | |
Updates to call to rabbit_control_main:emitting_map_with_wrapper_fun/5.
References #62
| -rw-r--r-- | src/rabbit_networking.erl | 8 |
1 files changed, 3 insertions, 5 deletions
diff --git a/src/rabbit_networking.erl b/src/rabbit_networking.erl index 7ccf7aadeb..e70582bf51 100644 --- a/src/rabbit_networking.erl +++ b/src/rabbit_networking.erl @@ -443,11 +443,9 @@ connection_info_all() -> cmap(fun (Q) -> connection_info(Q) end). connection_info_all(Items) -> cmap(fun (Q) -> connection_info(Q, Items) end). connection_info_all(Items, Ref, AggregatorPid) -> - cmap(fun(E) -> rabbit_control_main:emitting_map( - AggregatorPid, Ref, - fun(Q) -> connection_info(Q, Items) end, [E]) - end), - ok. + rabbit_control_main:emitting_map_with_wrapper_fun( + AggregatorPid, Ref, fun(Q) -> connection_info(Q, Items) end, + fun(F, L) -> rabbit_misc:filter_exit_map(F, L) end, connections()). close_connection(Pid, Explanation) -> rabbit_log:info("Closing connection ~p because ~p~n", [Pid, Explanation]), |