diff options
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_channel.erl | 10 |
1 files changed, 9 insertions, 1 deletions
diff --git a/src/rabbit_channel.erl b/src/rabbit_channel.erl index f8ed9cae9f..125b85cfc3 100644 --- a/src/rabbit_channel.erl +++ b/src/rabbit_channel.erl @@ -55,7 +55,8 @@ -export([start_link/11, do/2, do/3, do_flow/3, flush/1, shutdown/1]). -export([send_command/2, deliver/4, deliver_reply/2, send_credit_reply/2, send_drained/2]). --export([list/0, info_keys/0, info/1, info/2, info_all/0, info_all/1]). +-export([list/0, info_keys/0, info/1, info/2, info_all/0, info_all/1, + info_all/3]). -export([refresh_config_local/0, ready_for_close/1]). -export([force_event_refresh/1]). @@ -218,6 +219,7 @@ -spec(info/2 :: (pid(), rabbit_types:info_keys()) -> rabbit_types:infos()). -spec(info_all/0 :: () -> [rabbit_types:infos()]). -spec(info_all/1 :: (rabbit_types:info_keys()) -> [rabbit_types:infos()]). +-spec(info_all/3 :: (rabbit_types:info_keys(), reference(), pid()) -> 'ok'). -spec(refresh_config_local/0 :: () -> 'ok'). -spec(ready_for_close/1 :: (pid()) -> 'ok'). -spec(force_event_refresh/1 :: (reference()) -> 'ok'). @@ -325,6 +327,12 @@ info_all() -> info_all(Items) -> rabbit_misc:filter_exit_map(fun (C) -> info(C, Items) end, list()). +info_all(Items, Ref, Pid) -> + rabbit_misc:filter_exit_map(fun (C) -> Pid ! {Ref, info(C, Items)} end, + list()), + Pid ! {Ref, finished}, + ok. + refresh_config_local() -> rabbit_misc:upmap( fun (C) -> gen_server2:call(C, refresh_config, infinity) end, |