diff options
| author | dcorbacho <dparracorbacho@piotal.io> | 2019-09-13 14:51:14 +0100 |
|---|---|---|
| committer | dcorbacho <dparracorbacho@piotal.io> | 2019-09-13 14:51:14 +0100 |
| commit | 432fb82ae9de41846fa53ffcb0ca9c41bc16056f (patch) | |
| tree | 446adea18d9301b501b91e16b1945aa18fe3e45b /src | |
| parent | b00e82dc2cdd1043fefb3590d6bdd839fde0a523 (diff) | |
| download | rabbitmq-server-git-432fb82ae9de41846fa53ffcb0ca9c41bc16056f.tar.gz | |
Test rebalance
[#166480197]
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), |