From 6a3be4ce63e9e92f47e8299d4282ab111818315a Mon Sep 17 00:00:00 2001 From: Matthew Sackman Date: Wed, 25 May 2011 13:23:21 +0100 Subject: correct use of nodes() --- src/rabbit_mirror_queue_master.erl | 10 +++++----- 1 file 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), -- cgit v1.2.1