diff options
| author | Matthias Radestock <matthias@lshift.net> | 2010-04-30 18:31:25 +0100 |
|---|---|---|
| committer | Matthias Radestock <matthias@lshift.net> | 2010-04-30 18:31:25 +0100 |
| commit | c4cbc18a833b9b8c9ec09d5bcb975ee5895bb95a (patch) | |
| tree | 6f1984f7a9380b40b3a6312f2a85759abb5d76b7 /src | |
| parent | ad2797a3c86d3da1ecfaf1336f134af1f1b239a7 (diff) | |
| download | rabbitmq-server-git-c4cbc18a833b9b8c9ec09d5bcb975ee5895bb95a.tar.gz | |
cosmetic
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_amqqueue.erl | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/src/rabbit_amqqueue.erl b/src/rabbit_amqqueue.erl index 48d0edfce0..2d75b15b64 100644 --- a/src/rabbit_amqqueue.erl +++ b/src/rabbit_amqqueue.erl @@ -33,6 +33,7 @@ -export([start/0, declare/4, delete/3, purge/1]). -export([internal_declare/2, internal_delete/1, + maybe_run_queue_via_backing_queue/2, update_ram_duration/1, set_ram_duration_target/2, set_maximum_since_use/2]). -export([pseudo_queue/2]). @@ -43,7 +44,6 @@ -export([claim_queue/2]). -export([basic_get/3, basic_consume/8, basic_cancel/4]). -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]). @@ -109,9 +109,9 @@ -spec(notify_sent/2 :: (pid(), pid()) -> 'ok'). -spec(unblock/2 :: (pid(), pid()) -> '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(maybe_run_queue_via_backing_queue/2 :: (pid(), (fun ((A) -> A))) -> 'ok'). -spec(update_ram_duration/1 :: (pid()) -> 'ok'). -spec(set_ram_duration_target/2 :: (pid(), number()) -> 'ok'). -spec(set_maximum_since_use/2 :: (pid(), non_neg_integer()) -> 'ok'). @@ -335,10 +335,6 @@ flush_all(QPids, ChPid) -> 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( @@ -360,6 +356,10 @@ internal_delete(QueueName) -> ok end. +maybe_run_queue_via_backing_queue(QPid, Fun) -> + gen_server2:pcall(QPid, 7, {maybe_run_queue_via_backing_queue, Fun}, + infinity). + update_ram_duration(QPid) -> gen_server2:pcast(QPid, 8, update_ram_duration). |