diff options
| author | Jean-Sébastien Pédron <jean-sebastien@rabbitmq.com> | 2020-05-11 12:27:37 +0200 |
|---|---|---|
| committer | Jean-Sébastien Pédron <jean-sebastien@rabbitmq.com> | 2020-05-11 12:27:37 +0200 |
| commit | 2240f746181087c44c71f35ce849944fd27b754a (patch) | |
| tree | 995b4f64d752952eb8bb5229a74c92741ebe3d0b /src | |
| parent | b6a38916400891e5e82a9c5c53cabb03c238769d (diff) | |
| download | rabbitmq-server-git-2240f746181087c44c71f35ce849944fd27b754a.tar.gz | |
rabbit_amqqueue: Fix spec of list_local_mirrored_classic_without_synchronised_mirrors_for_cli/0
The return value was incorrectly spec'd.
Reported by Dialyzer.
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_amqqueue.erl | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/src/rabbit_amqqueue.erl b/src/rabbit_amqqueue.erl index b4d0a45e70..bb6fd2932e 100644 --- a/src/rabbit_amqqueue.erl +++ b/src/rabbit_amqqueue.erl @@ -1088,7 +1088,8 @@ list_local_mirrored_classic_names() -> is_local_to_node(amqqueue:get_pid(Q), node()), is_replicated(Q)]. --spec list_local_mirrored_classic_without_synchronised_mirrors() -> [amqqueue:amqqueue()]. +-spec list_local_mirrored_classic_without_synchronised_mirrors() -> + [amqqueue:amqqueue()]. list_local_mirrored_classic_without_synchronised_mirrors() -> [ Q || Q <- list(), amqqueue:get_state(Q) =/= crashed, @@ -1097,7 +1098,8 @@ list_local_mirrored_classic_without_synchronised_mirrors() -> is_replicated(Q), not has_synchronised_mirrors_online(Q)]. --spec list_local_mirrored_classic_without_synchronised_mirrors_for_cli() -> [amqqueue:amqqueue()]. +-spec list_local_mirrored_classic_without_synchronised_mirrors_for_cli() -> + [#{binary => any()}]. list_local_mirrored_classic_without_synchronised_mirrors_for_cli() -> ClassicQs = list_local_mirrored_classic_without_synchronised_mirrors(), [begin |