diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2014-04-15 11:11:01 +0100 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2014-04-15 11:11:01 +0100 |
| commit | 8ab07853c408af4d85baaaa7e2d2264eba19668d (patch) | |
| tree | 7d06a5578031361c0fd7fe8b07e5644f7918966e | |
| parent | e2ff06ff0405957c3dfee42905de295273123d49 (diff) | |
| parent | 1160d065888258946f9585b3aa40c00d3470728a (diff) | |
| download | rabbitmq-server-git-8ab07853c408af4d85baaaa7e2d2264eba19668d.tar.gz | |
Merge bug26115
| -rw-r--r-- | src/rabbit_mirror_queue_slave.erl | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/src/rabbit_mirror_queue_slave.erl b/src/rabbit_mirror_queue_slave.erl index ee9f77012b..e5c3adac06 100644 --- a/src/rabbit_mirror_queue_slave.erl +++ b/src/rabbit_mirror_queue_slave.erl @@ -166,13 +166,13 @@ init_it(Self, GM, Node, QName) -> end; [SPid] -> case rabbit_misc:is_process_alive(SPid) of true -> existing; - false -> GMPids = [T || T = {_, S} <- GMPids, - S =/= SPid], + false -> GMPids1 = [T || T = {_, S} <- GMPids, + S =/= SPid], Q1 = Q#amqqueue{ slave_pids = SPids -- [SPid], - gm_pids = GMPids}, + gm_pids = GMPids1}, add_slave(Q1, Self, GM), - {new, QPid, GMPids} + {new, QPid, GMPids1} end end; [] -> |