diff options
| author | Matthew Sackman <matthew@rabbitmq.com> | 2010-12-20 16:17:04 +0000 |
|---|---|---|
| committer | Matthew Sackman <matthew@rabbitmq.com> | 2010-12-20 16:17:04 +0000 |
| commit | 70aac947f7eb5320fb27792af203f0e201dfd7ba (patch) | |
| tree | db3041d0a441d85184979e8c82ce38d3a48da203 /src | |
| parent | c1cc82f75d702329ef8007ab6ecaaade645edbd7 (diff) | |
| download | rabbitmq-server-git-70aac947f7eb5320fb27792af203f0e201dfd7ba.tar.gz | |
Remove R14-ism. Also, cute feature - if you specify no nodes by name, you mean all known nodes
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_mirror_queue_master.erl | 8 |
1 files changed, 6 insertions, 2 deletions
diff --git a/src/rabbit_mirror_queue_master.erl b/src/rabbit_mirror_queue_master.erl index 94e93b3e80..4f1bcc9dc3 100644 --- a/src/rabbit_mirror_queue_master.erl +++ b/src/rabbit_mirror_queue_master.erl @@ -57,8 +57,12 @@ init(#amqqueue { arguments = Args } = Q, Recover) -> {ok, CPid} = rabbit_mirror_queue_coordinator:start_link(Q, undefined), GM = rabbit_mirror_queue_coordinator:get_gm(CPid), {_Type, Nodes} = rabbit_misc:table_lookup(Args, <<"x-mirror">>), - [rabbit_mirror_queue_coordinator:add_slave(CPid, binary_to_atom(Node, utf8)) - || {longstr, Node} <- Nodes], + Nodes1 = case Nodes of + [] -> nodes(); + _ -> [list_to_atom(binary_to_list(Node)) || + {longstr, Node} <- Nodes] + end, + [rabbit_mirror_queue_coordinator:add_slave(CPid, Node) || Node <- Nodes1], {ok, BQ} = application:get_env(backing_queue_module), BQS = BQ:init(Q, Recover), #state { gm = GM, |