diff options
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_mirror_queue_misc.erl | 2 | ||||
| -rw-r--r-- | src/rabbit_queue_master_location_misc.erl | 2 |
2 files changed, 2 insertions, 2 deletions
diff --git a/src/rabbit_mirror_queue_misc.erl b/src/rabbit_mirror_queue_misc.erl index 375a0366dd..0b6f6833f6 100644 --- a/src/rabbit_mirror_queue_misc.erl +++ b/src/rabbit_mirror_queue_misc.erl @@ -19,7 +19,7 @@ -export([remove_from_queue/3, on_node_up/0, add_mirrors/3, report_deaths/4, store_updated_slaves/1, - initial_queue_node/2, suggested_queue_nodes/1, + initial_queue_node/2, suggested_queue_nodes/1, actual_queue_nodes/1, is_mirrored/1, update_mirrors/2, update_mirrors/1, validate_policy/1, maybe_auto_sync/1, maybe_drop_master_after_sync/1, sync_batch_size/1, log_info/3, log_warning/3]). diff --git a/src/rabbit_queue_master_location_misc.erl b/src/rabbit_queue_master_location_misc.erl index 02bc9387ef..2e8f92a2b3 100644 --- a/src/rabbit_queue_master_location_misc.erl +++ b/src/rabbit_queue_master_location_misc.erl @@ -95,7 +95,7 @@ get_location_mod_by_config(#amqqueue{}) -> all_nodes(Queue = #amqqueue{}) -> handle_suggested_queue_nodes(rabbit_mirror_queue_misc:suggested_queue_nodes(Queue)). -handle_suggested_queue_nodes({MNode, []}) -> +handle_suggested_queue_nodes({_MNode, []}) -> rabbit_nodes:all_running(); handle_suggested_queue_nodes({MNode, SNodes}) -> [MNode | SNodes]. |