diff options
| author | Matthew Sackman <matthew@lshift.net> | 2009-06-17 17:40:23 +0100 |
|---|---|---|
| committer | Matthew Sackman <matthew@lshift.net> | 2009-06-17 17:40:23 +0100 |
| commit | 5b76f375732b0598ae75243ff0642b4cbbb8b919 (patch) | |
| tree | e76c88a8594c91ffccca3609665244570d782de9 /src | |
| parent | 1e82dd6080d98a8403dc8895587901e9716b873e (diff) | |
| download | rabbitmq-server-git-5b76f375732b0598ae75243ff0642b4cbbb8b919.tar.gz | |
preemptive tidying
Diffstat (limited to 'src')
| -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()). |