diff options
| author | Ayanda Dube <ayanda.dube@erlang-solutions.com> | 2015-10-16 01:52:15 +0100 |
|---|---|---|
| committer | Ayanda Dube <ayanda.dube@erlang-solutions.com> | 2015-10-16 01:52:15 +0100 |
| commit | 20396c64ca74caa9696ea268a9cb1b991b08d652 (patch) | |
| tree | 827efed209d9a274fbd633ae081b61a7957ea9c2 | |
| parent | aa7ca9bfc8fe92be5ec52df1d21fcd27f7381093 (diff) | |
| download | rabbitmq-server-git-20396c64ca74caa9696ea268a9cb1b991b08d652.tar.gz | |
Updates to call to rabbit_control_main:emitting_map_with_wrapper_fun/5.
References #62
| -rw-r--r-- | src/rabbit_channel.erl | 9 |
1 files changed, 3 insertions, 6 deletions
diff --git a/src/rabbit_channel.erl b/src/rabbit_channel.erl index 670d7a9838..86985de90d 100644 --- a/src/rabbit_channel.erl +++ b/src/rabbit_channel.erl @@ -328,12 +328,9 @@ info_all(Items) -> rabbit_misc:filter_exit_map(fun (C) -> info(C, Items) end, list()). info_all(Items, Ref, AggregatorPid) -> - rabbit_misc:filter_exit_map( - fun(E) -> rabbit_control_main:emitting_map( - AggregatorPid, Ref, fun(C) -> info(C, Items) end, [E]) - end, - list()), - ok. + rabbit_control_main:emitting_map_with_wrapper_fun( + AggregatorPid, Ref, fun(C) -> info(C, Items) end, + fun(F, L) -> rabbit_misc:filter_exit_map(F, L) end, list()). refresh_config_local() -> rabbit_misc:upmap( |