diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2012-09-05 14:54:17 +0100 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2012-09-05 14:54:17 +0100 |
| commit | 387b845fdc29dd3e0c335f6aa8f3e5f49e835665 (patch) | |
| tree | 53b150a8595749f28158586d0a6b72041f21433c /src | |
| parent | 5f049990899e7646e43296066051de2c578b49e9 (diff) | |
| download | rabbitmq-server-git-387b845fdc29dd3e0c335f6aa8f3e5f49e835665.tar.gz | |
Also exclude DeadNodes from the list of new nodes to start mirrors on; we have checked for running_clustered_nodes() but that could be out of date.
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_mirror_queue_misc.erl | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/src/rabbit_mirror_queue_misc.erl b/src/rabbit_mirror_queue_misc.erl index 5217e27604..ad9dfa0d1b 100644 --- a/src/rabbit_mirror_queue_misc.erl +++ b/src/rabbit_mirror_queue_misc.erl @@ -101,7 +101,7 @@ remove_from_queue0(QueueName, DeadGMPids) -> {_, OldNodes} = actual_queue_nodes(Q1), {_, NewNodes} = suggested_queue_nodes(Q1), {ok, QPid1, [QPid | SPids] -- Alive, - NewNodes -- OldNodes}; + (NewNodes -- OldNodes) -- DeadNodes}; _ -> %% Master has changed, and we're not it, %% so leave alone to allow the promoted |