diff options
| author | Luke Bakken <lbakken@pivotal.io> | 2017-09-21 08:20:37 -0700 |
|---|---|---|
| committer | Luke Bakken <lbakken@pivotal.io> | 2017-09-22 11:23:33 -0700 |
| commit | cfec7c2d0fc009a40d2b545daa4fd70d636e087f (patch) | |
| tree | 4fc651b4ffca572b84e401958ea8196ec5473d24 /src | |
| parent | ba1df05f1c2361ba9983b9775d7b5fb51508e7a5 (diff) | |
| download | rabbitmq-server-git-cfec7c2d0fc009a40d2b545daa4fd70d636e087f.tar.gz | |
Handle suggested_queue_nodes output when slave nodes are empty
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_queue_master_location_misc.erl | 6 |
1 files changed, 5 insertions, 1 deletions
diff --git a/src/rabbit_queue_master_location_misc.erl b/src/rabbit_queue_master_location_misc.erl index bb2329b958..02bc9387ef 100644 --- a/src/rabbit_queue_master_location_misc.erl +++ b/src/rabbit_queue_master_location_misc.erl @@ -93,5 +93,9 @@ get_location_mod_by_config(#amqqueue{}) -> end. all_nodes(Queue = #amqqueue{}) -> - {MNode, SNodes} = rabbit_mirror_queue_misc:suggested_queue_nodes(Queue), + handle_suggested_queue_nodes(rabbit_mirror_queue_misc:suggested_queue_nodes(Queue)). + +handle_suggested_queue_nodes({MNode, []}) -> + rabbit_nodes:all_running(); +handle_suggested_queue_nodes({MNode, SNodes}) -> [MNode | SNodes]. |