diff options
| -rw-r--r-- | src/rabbit_queue_location_min_masters.erl | 2 | ||||
| -rw-r--r-- | src/rabbit_queue_location_random.erl | 2 | ||||
| -rw-r--r-- | src/rabbit_queue_master_location_misc.erl | 4 |
3 files changed, 4 insertions, 4 deletions
diff --git a/src/rabbit_queue_location_min_masters.erl b/src/rabbit_queue_location_min_masters.erl index 8fc8d47aae..5d6f568d4a 100644 --- a/src/rabbit_queue_location_min_masters.erl +++ b/src/rabbit_queue_location_min_masters.erl @@ -37,7 +37,7 @@ description() -> [{description, <<"Locate queue master node from cluster node with least bound queues">>}]. -queue_master_location(#amqqueue{}=Q) -> +queue_master_location(#amqqueue{} = Q) -> Cluster = rabbit_queue_master_location_misc:all_nodes(Q), VHosts = rabbit_vhost:list(), BoundQueueMasters = get_bound_queue_masters_per_vhost(VHosts, []), diff --git a/src/rabbit_queue_location_random.erl b/src/rabbit_queue_location_random.erl index 9f318b9359..d103d3f126 100644 --- a/src/rabbit_queue_location_random.erl +++ b/src/rabbit_queue_location_random.erl @@ -37,7 +37,7 @@ description() -> [{description, <<"Locate queue master node from cluster in a random manner">>}]. -queue_master_location(#amqqueue{}=Q) -> +queue_master_location(#amqqueue{} = Q) -> Cluster = rabbit_queue_master_location_misc:all_nodes(Q), RandomPos = erlang:phash2(time_compat:monotonic_time(), length(Cluster)), MasterNode = lists:nth(RandomPos + 1, Cluster), diff --git a/src/rabbit_queue_master_location_misc.erl b/src/rabbit_queue_master_location_misc.erl index 0e3dec9b83..bb2329b958 100644 --- a/src/rabbit_queue_master_location_misc.erl +++ b/src/rabbit_queue_master_location_misc.erl @@ -92,6 +92,6 @@ get_location_mod_by_config(#amqqueue{}) -> _ -> {error, "queue_master_locator undefined"} end. -all_nodes(Queue=#amqqueue{}) -> +all_nodes(Queue = #amqqueue{}) -> {MNode, SNodes} = rabbit_mirror_queue_misc:suggested_queue_nodes(Queue), - [MNode|SNodes]. + [MNode | SNodes]. |