diff options
| -rw-r--r-- | src/rabbit_mixed_queue.erl | 30 |
1 files changed, 12 insertions, 18 deletions
diff --git a/src/rabbit_mixed_queue.erl b/src/rabbit_mixed_queue.erl index 9aa290a0bd..e7ac171c6a 100644 --- a/src/rabbit_mixed_queue.erl +++ b/src/rabbit_mixed_queue.erl @@ -59,30 +59,24 @@ length :: non_neg_integer() }). -type(acktag() :: ( 'noack' | { non_neg_integer(), non_neg_integer() })). +-type(okmqs() :: {'ok', mqstate()}). --spec(init/3 :: (queue_name(), bool(), mode()) -> - {'ok', mqstate()}). --spec(publish/2 :: (message(), mqstate()) -> - {'ok', mqstate()}). +-spec(init/3 :: (queue_name(), bool(), mode()) -> okmqs()). +-spec(publish/2 :: (message(), mqstate()) -> okmqs()). -spec(publish_delivered/2 :: (message(), mqstate()) -> {'ok', acktag(), mqstate()}). -spec(deliver/1 :: (mqstate()) -> {('empty' | {message(), bool(), acktag(), non_neg_integer()}), mqstate()}). --spec(ack/2 :: ([acktag()], mqstate()) -> - {'ok', mqstate()}). --spec(tx_publish/2 :: (message(), mqstate()) -> - {'ok', mqstate()}). --spec(tx_commit/3 :: ([message()], [acktag()], mqstate()) -> - {'ok', mqstate()}). --spec(tx_cancel/2 :: ([message()], mqstate()) -> - {'ok', mqstate()}). --spec(requeue/2 :: ([{message(), acktag()}], mqstate()) -> - {'ok', mqstate()}). --spec(purge/1 :: (mqstate()) -> - {'ok', mqstate()}). --spec(delete_queue/1 :: (mqstate()) -> - {'ok', mqstate()}). +-spec(ack/2 :: ([acktag()], mqstate()) -> okmqs()). +-spec(tx_publish/2 :: (message(), mqstate()) -> okmqs()). +-spec(tx_commit/3 :: ([message()], [acktag()], mqstate()) -> okmqs()). +-spec(tx_cancel/2 :: ([message()], mqstate()) -> okmqs()). +-spec(requeue/2 :: ([{message(), acktag()}], mqstate()) -> okmqs()). +-spec(purge/1 :: (mqstate()) -> okmqs()). + +-spec(delete_queue/1 :: (mqstate()) -> {'ok', mqstate()}). + -spec(length/1 :: (mqstate()) -> non_neg_integer()). -spec(is_empty/1 :: (mqstate()) -> bool()). |