diff options
| -rw-r--r-- | src/rabbit_amqqueue.erl | 9 |
1 files changed, 4 insertions, 5 deletions
diff --git a/src/rabbit_amqqueue.erl b/src/rabbit_amqqueue.erl index 7628d1097d..d566ac8748 100644 --- a/src/rabbit_amqqueue.erl +++ b/src/rabbit_amqqueue.erl @@ -694,11 +694,10 @@ safe_delegate_call_ok(F, Pids) -> fun () -> ok end, fun () -> F(Pid) end) end), - case lists:filter(fun ({_Pid, {exit, {R, _}, _}}) -> - rabbit_misc:is_abnormal_exit(R); - ({_Pid, _}) -> - false - end, Bads) of + case lists:filter( + fun ({_Pid, {exit, {R, _}, _}}) -> rabbit_misc:is_abnormal_exit(R); + ({_Pid, _}) -> false + end, Bads) of [] -> ok; Bads1 -> {error, Bads1} end. |