diff options
| -rw-r--r-- | src/rabbit_mirror_queue_master.erl | 16 |
1 files changed, 8 insertions, 8 deletions
diff --git a/src/rabbit_mirror_queue_master.erl b/src/rabbit_mirror_queue_master.erl index dd2e76a1d6..463b8cfb2d 100644 --- a/src/rabbit_mirror_queue_master.erl +++ b/src/rabbit_mirror_queue_master.erl @@ -71,18 +71,18 @@ sender_death_fun() -> end) end. -init(#amqqueue { arguments = Args, name = QName } = Q, Recover, +init(#amqqueue { name = QName, mirror_nodes = MNodes } = Q, Recover, AsyncCallback, SyncCallback) -> {ok, CPid} = rabbit_mirror_queue_coordinator:start_link( 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 - [] -> rabbit_mnesia:all_clustered_nodes(); - _ -> [list_to_atom(binary_to_list(Node)) || - {longstr, Node} <- Nodes] - end) -- [node()], - [rabbit_mirror_queue_misc:add_mirror(QName, Node) || Node <- Nodes1], + MNodes1 = + (case MNodes of + all -> rabbit_mnesia:all_clustered_nodes(); + undefined -> []; + _ -> [list_to_atom(binary_to_list(Node)) || Node <- MNodes] + end) -- [node()], + [rabbit_mirror_queue_misc:add_mirror(QName, Node) || Node <- MNodes1], {ok, BQ} = application:get_env(backing_queue_module), BQS = BQ:init(Q, Recover, AsyncCallback, SyncCallback), #state { gm = GM, |