diff options
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_mirror_queue_misc.erl | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/src/rabbit_mirror_queue_misc.erl b/src/rabbit_mirror_queue_misc.erl index 85c8eab10d..c1ae96b02f 100644 --- a/src/rabbit_mirror_queue_misc.erl +++ b/src/rabbit_mirror_queue_misc.erl @@ -542,7 +542,8 @@ queue_length(Q) -> M. get_replicas(Q) -> - rabbit_mnesia:cluster_nodes(running). + {MNode, SNodes} = suggested_queue_nodes(Q), + [MNode] ++ SNodes. transfer_leadership(Q, Destination) -> QName = amqqueue:get_name(Q), |