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 | 319e174ea20f9df542da293f137e630a17e4ff28 (patch) | |
| tree | 7d06a5578031361c0fd7fe8b07e5644f7918966e | |
| parent | 07cfa2ebfdf6144436248e12880ef6f5db792c0a (diff) | |
| parent | 61eefc62433751cdbc8fd7d186aff2bdc42fe805 (diff) | |
| download | rabbitmq-server-319e174ea20f9df542da293f137e630a17e4ff28.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 ee9f7701..e5c3adac 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; [] -> |