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 | 0ca599b3a28ca43ae4b0adc74f91ee7d7a5f293b (patch) | |
| tree | 2efd938cab1fad9ac084bda9b711804cff7adf1b /src/rabbit_router.erl | |
| parent | afcb8fd9722a1a4a5a8eccac9811e4c9cd6d0c32 (diff) | |
| download | rabbitmq-server-0ca599b3a28ca43ae4b0adc74f91ee7d7a5f293b.tar.gz | |
turn rabbit_router into gen_server2bug20179
...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.
Diffstat (limited to 'src/rabbit_router.erl')
| -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 26d857be..ff42ea04 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}. |