diff options
| author | Matthias Radestock <matthias@lshift.net> | 2010-04-30 16:40:35 +0100 |
|---|---|---|
| committer | Matthias Radestock <matthias@lshift.net> | 2010-04-30 16:40:35 +0100 |
| commit | 6c0a44b866048162b44f49791305d9caab7d1800 (patch) | |
| tree | 95f8f484bade62554b4413452d7d9372d1c05743 | |
| parent | 5e52def50bfb33718cf8a518f4011c67187d947e (diff) | |
| download | rabbitmq-server-git-6c0a44b866048162b44f49791305d9caab7d1800.tar.gz | |
cosmetic
| -rw-r--r-- | src/rabbit_amqqueue.erl | 19 |
1 files changed, 10 insertions, 9 deletions
diff --git a/src/rabbit_amqqueue.erl b/src/rabbit_amqqueue.erl index ee769d5508..48d0edfce0 100644 --- a/src/rabbit_amqqueue.erl +++ b/src/rabbit_amqqueue.erl @@ -32,8 +32,9 @@ -module(rabbit_amqqueue). -export([start/0, declare/4, delete/3, purge/1]). --export([internal_declare/2, internal_delete/1, update_ram_duration/1, - set_ram_duration_target/2, set_maximum_since_use/2]). +-export([internal_declare/2, internal_delete/1, + update_ram_duration/1, set_ram_duration_target/2, + set_maximum_since_use/2]). -export([pseudo_queue/2]). -export([lookup/1, with/2, with_or_die/2, stat/1, stat_all/0, deliver/2, requeue/3, ack/4]). @@ -41,8 +42,8 @@ -export([consumers/1, consumers_all/1]). -export([claim_queue/2]). -export([basic_get/3, basic_consume/8, basic_cancel/4]). --export([notify_sent/2, unblock/2, maybe_run_queue_via_backing_queue/2, - flush_all/2]). +-export([notify_sent/2, unblock/2, flush_all/2]). +-export([maybe_run_queue_via_backing_queue/2]). -export([commit_all/3, rollback_all/3, notify_down_all/2, limit_all/3]). -export([on_node_down/1]). @@ -107,8 +108,8 @@ -spec(basic_cancel/4 :: (amqqueue(), pid(), ctag(), any()) -> 'ok'). -spec(notify_sent/2 :: (pid(), pid()) -> 'ok'). -spec(unblock/2 :: (pid(), pid()) -> 'ok'). --spec(maybe_run_queue_via_backing_queue/2 :: (pid(), (fun ((A) -> A))) -> 'ok'). -spec(flush_all/2 :: ([pid()], pid()) -> 'ok'). +-spec(maybe_run_queue_via_backing_queue/2 :: (pid(), (fun ((A) -> A))) -> 'ok'). -spec(internal_declare/2 :: (amqqueue(), boolean()) -> amqqueue()). -spec(internal_delete/1 :: (queue_name()) -> 'ok' | not_found()). -spec(update_ram_duration/1 :: (pid()) -> 'ok'). @@ -328,16 +329,16 @@ notify_sent(QPid, ChPid) -> unblock(QPid, ChPid) -> gen_server2:pcast(QPid, 7, {unblock, ChPid}). -maybe_run_queue_via_backing_queue(QPid, Fun) -> - gen_server2:pcall(QPid, 7, {maybe_run_queue_via_backing_queue, Fun}, - infinity). - flush_all(QPids, ChPid) -> safe_pmap_ok( fun (_) -> ok end, fun (QPid) -> gen_server2:cast(QPid, {flush, ChPid}) end, QPids). +maybe_run_queue_via_backing_queue(QPid, Fun) -> + gen_server2:pcall(QPid, 7, {maybe_run_queue_via_backing_queue, Fun}, + infinity). + internal_delete(QueueName) -> case rabbit_misc:execute_mnesia_transaction( |