diff options
| -rw-r--r-- | src/rabbit_queue_location_min_masters.erl | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/src/rabbit_queue_location_min_masters.erl b/src/rabbit_queue_location_min_masters.erl index ee7a1339b1..21c3bdb045 100644 --- a/src/rabbit_queue_location_min_masters.erl +++ b/src/rabbit_queue_location_min_masters.erl @@ -48,10 +48,11 @@ queue_master_location(#amqqueue{}) -> %% Private helper functions %%--------------------------------------------------------------------------- get_min_master(Cluster, BoundQueueMasters) -> - lists:min([ {count_masters(Node, BoundQueueMasters), Node} || Node <- Cluster ]). + lists:min([ {count_masters(Node, BoundQueueMasters), Node} || + Node <- Cluster ]). count_masters(Node, Masters) -> - length([ X || X <- Masters, X == Node ]). + length([ X || X <- Masters, X == Node ]). get_bound_queue_masters_per_vhost([], Acc) -> lists:flatten(Acc); |