diff options
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_networking.erl | 3 |
1 files changed, 1 insertions, 2 deletions
diff --git a/src/rabbit_networking.erl b/src/rabbit_networking.erl index 3a3357ba9d..f968b0d890 100644 --- a/src/rabbit_networking.erl +++ b/src/rabbit_networking.erl @@ -242,8 +242,7 @@ connection_info_all() -> cmap(fun (Q) -> connection_info(Q) end). connection_info_all(Items) -> cmap(fun (Q) -> connection_info(Q, Items) end). close_connection(Pid, Explanation) -> - case lists:any(fun ({_, ChildPid, _, _}) -> ChildPid =:= Pid end, - supervisor:which_children(rabbit_tcp_client_sup)) of + case lists:member(Pid, connections()) of true -> rabbit_reader:shutdown(Pid, Explanation); false -> throw({error, {not_a_connection_pid, Pid}}) end. |