diff options
| author | Jean-Sébastien Pédron <jean-sebastien@rabbitmq.com> | 2020-05-11 12:37:57 +0200 |
|---|---|---|
| committer | Jean-Sébastien Pédron <jean-sebastien@rabbitmq.com> | 2020-05-11 12:37:57 +0200 |
| commit | d842299783ddf5f05f399de13f352f278260f8b5 (patch) | |
| tree | 742321b8c1e8593e06dbfce188fc426cdd3e3cf5 /src | |
| parent | 57a81b95a14823c3a0bc2a8f655d2b1b48c944ea (diff) | |
| download | rabbitmq-server-git-d842299783ddf5f05f399de13f352f278260f8b5.tar.gz | |
rabbit_quorum_queue: Fix type spec
Reported by Dialyzer.
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_quorum_queue.erl | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/src/rabbit_quorum_queue.erl b/src/rabbit_quorum_queue.erl index 944fc6bae5..62ed6e3ef9 100644 --- a/src/rabbit_quorum_queue.erl +++ b/src/rabbit_quorum_queue.erl @@ -618,7 +618,8 @@ basic_get(Q, NoAck, CTag0, QState0) when ?amqqueue_is_quorum(Q) -> rabbit_types:ctag(), ExclusiveConsume :: boolean(), Args :: rabbit_framing:amqp_table(), ActingUser :: binary(), any(), rabbit_fifo_client:state()) -> - {'ok', rabbit_fifo_client:state()}. + {'ok', rabbit_fifo_client:state()} | + {error, timeout | term()}. basic_consume(Q, NoAck, ChPid, ConsumerPrefetchCount, ConsumerTag0, ExclusiveConsume, Args, |