summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorEmile Joubert <emile@rabbitmq.com>2011-10-04 14:02:22 +0100
committerEmile Joubert <emile@rabbitmq.com>2011-10-04 14:02:22 +0100
commit377e4dbe191e5f9957e958dea0a49512cbc37ec5 (patch)
treed5c017c170662cd8c0ee49c0e6acd3e750d6070f
parent587e3cf8aa4c4308662b957b1a374a468402f70c (diff)
parentc081bfb3a1685c340118bf187344ab634a256cc0 (diff)
downloadrabbitmq-server-git-377e4dbe191e5f9957e958dea0a49512cbc37ec5.tar.gz
Merged bug24462 into default
-rw-r--r--src/rabbit_mirror_queue_master.erl2
1 files changed, 1 insertions, 1 deletions
diff --git a/src/rabbit_mirror_queue_master.erl b/src/rabbit_mirror_queue_master.erl
index 5fc6341f50..328fe639f7 100644
--- a/src/rabbit_mirror_queue_master.erl
+++ b/src/rabbit_mirror_queue_master.erl
@@ -95,7 +95,7 @@ init(#amqqueue { name = QName, mirror_nodes = MNodes } = Q, Recover,
(case MNodes of
all -> rabbit_mnesia:all_clustered_nodes();
undefined -> [];
- _ -> [list_to_atom(binary_to_list(Node)) || Node <- MNodes]
+ _ -> MNodes
end) -- [node()],
[rabbit_mirror_queue_misc:add_mirror(QName, Node) || Node <- MNodes1],
{ok, BQ} = application:get_env(backing_queue_module),