diff options
| -rw-r--r-- | src/rabbit_mirror_queue_misc.erl | 5 |
1 files changed, 1 insertions, 4 deletions
diff --git a/src/rabbit_mirror_queue_misc.erl b/src/rabbit_mirror_queue_misc.erl index ae1004c3e2..d1de786103 100644 --- a/src/rabbit_mirror_queue_misc.erl +++ b/src/rabbit_mirror_queue_misc.erl @@ -74,10 +74,7 @@ remove_from_queue(QueueName, DeadGMPids) -> lists:member(GM, DeadGMPids) end, GMPids), DeadPids = [Pid || {_GM, Pid} <- Dead, Pid =/= existing], - {_, Alive} = lists:partition( - fun (Pid) -> - lists:member(Pid, DeadPids) - end, [QPid | SPids]), + Alive = [QPid | SPids] -- DeadPids, {QPid1, SPids1} = promote_slave(Alive), case {{QPid, SPids, GMPids}, {QPid1, SPids1, GMPids1}} of |