diff options
| author | Matthew Sackman <matthew@rabbitmq.com> | 2011-05-25 13:23:21 +0100 |
|---|---|---|
| committer | Matthew Sackman <matthew@rabbitmq.com> | 2011-05-25 13:23:21 +0100 |
| commit | 6a3be4ce63e9e92f47e8299d4282ab111818315a (patch) | |
| tree | 3ebef23340bfdf107742cda68eddb0854db90c75 | |
| parent | ed73a0d3c85aa3bd0fe7226f4c3c7de0f1452f02 (diff) | |
| download | rabbitmq-server-6a3be4ce63e9e92f47e8299d4282ab111818315a.tar.gz | |
correct use of nodes()
| -rw-r--r-- | src/rabbit_mirror_queue_master.erl | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/src/rabbit_mirror_queue_master.erl b/src/rabbit_mirror_queue_master.erl index 9bd8565f..da12ea82 100644 --- a/src/rabbit_mirror_queue_master.erl +++ b/src/rabbit_mirror_queue_master.erl @@ -77,11 +77,11 @@ init(#amqqueue { arguments = Args, name = QName } = Q, Recover, Q, undefined, sender_death_fun()), GM = rabbit_mirror_queue_coordinator:get_gm(CPid), {_Type, Nodes} = rabbit_misc:table_lookup(Args, <<"x-mirror">>), - Nodes1 = case Nodes of - [] -> nodes(); - _ -> [list_to_atom(binary_to_list(Node)) || - {longstr, Node} <- Nodes] - end, + Nodes1 = (case Nodes of + [] -> rabbit_mnesia:all_clustered_nodes(); + _ -> [list_to_atom(binary_to_list(Node)) || + {longstr, Node} <- Nodes] + end) -- [node()], [rabbit_mirror_queue_misc:add_slave(QName, Node) || Node <- Nodes1], {ok, BQ} = application:get_env(backing_queue_module), BQS = BQ:init(Q, Recover, AsyncCallback, SyncCallback), |