diff options
| author | Matthias Radestock <matthias@lshift.net> | 2009-01-21 20:13:09 +0000 |
|---|---|---|
| committer | Matthias Radestock <matthias@lshift.net> | 2009-01-21 20:13:09 +0000 |
| commit | 6a7d628eba8abde44601474982dfdfcd2fceb295 (patch) | |
| tree | 2efd938cab1fad9ac084bda9b711804cff7adf1b | |
| parent | 33d0c4627618c5fbde6b2a85483ed038f4dba293 (diff) | |
| download | rabbitmq-server-git-6a7d628eba8abde44601474982dfdfcd2fceb295.tar.gz | |
turn rabbit_router into gen_server2
...in order to protect it from the effects of long message queues.
This isn't actually relevant at the moment because the bulk of the
router code is disabled in order to deal with bug 19758. But we will
re-enable that code eventually.
| -rw-r--r-- | src/rabbit_router.erl | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/src/rabbit_router.erl b/src/rabbit_router.erl index 26d857bef0..ff42ea0460 100644 --- a/src/rabbit_router.erl +++ b/src/rabbit_router.erl @@ -32,7 +32,7 @@ -module(rabbit_router). -include("rabbit.hrl"). --behaviour(gen_server). +-behaviour(gen_server2). -export([start_link/0, deliver/5]). @@ -58,7 +58,7 @@ %%---------------------------------------------------------------------------- start_link() -> - gen_server:start_link({local, ?SERVER}, ?MODULE, [], []). + gen_server2:start_link({local, ?SERVER}, ?MODULE, [], []). -ifdef(BUG19758). @@ -143,7 +143,7 @@ handle_call({deliver, QPids, Mandatory, Immediate, Txn, Message}, spawn( fun () -> R = run_bindings(QPids, Mandatory, Immediate, Txn, Message), - gen_server:reply(From, R) + gen_server2:reply(From, R) end), {noreply, State}. |