diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2012-08-23 15:24:37 +0100 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2012-08-23 15:24:37 +0100 |
| commit | bf31e4e01ff5036720bb2445f057674012300c43 (patch) | |
| tree | f8461d28f0cd937bd743db7fcacc89dd01bc5ac7 | |
| parent | 6bc19d6d7e6ccd7305389335f88736719be3eb02 (diff) | |
| download | rabbitmq-server-bf31e4e01ff5036720bb2445f057674012300c43.tar.gz | |
Suggest queue nodes based on running nodes, otherwise (at the very least) we can immediately try to start a mirror on a node that has just gone down.
| -rw-r--r-- | src/rabbit_mirror_queue_misc.erl | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/src/rabbit_mirror_queue_misc.erl b/src/rabbit_mirror_queue_misc.erl index e4591cca..7caa96b5 100644 --- a/src/rabbit_mirror_queue_misc.erl +++ b/src/rabbit_mirror_queue_misc.erl @@ -233,7 +233,8 @@ suggested_queue_nodes(Q) -> _ -> MNode0 end, suggested_queue_nodes(policy(<<"ha-mode">>, Q), policy(<<"ha-params">>, Q), - {MNode, SNodes}, rabbit_mnesia:all_clustered_nodes()). + {MNode, SNodes}, + rabbit_mnesia:running_clustered_nodes()). policy(Policy, Q) -> case rabbit_policy:get(Policy, Q) of |