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 | 05ca535913410d1ed7aa5e78a20e8094372847c5 (patch) | |
| tree | f8461d28f0cd937bd743db7fcacc89dd01bc5ac7 | |
| parent | 6d6ffaf4487d40ecafcc94bbe7b44b3f0a0b762a (diff) | |
| download | rabbitmq-server-git-05ca535913410d1ed7aa5e78a20e8094372847c5.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 e4591ccabb..7caa96b5de 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 |