diff options
| author | Simon MacMullen <simon@lshift.net> | 2010-04-09 14:14:39 +0100 |
|---|---|---|
| committer | Simon MacMullen <simon@lshift.net> | 2010-04-09 14:14:39 +0100 |
| commit | ecd46b56aaf59389b98466dbe9eb6e8a265710d4 (patch) | |
| tree | d33c70ede7699c0038abffa98c80a604d0a6f1b6 /src/rabbit_router.erl | |
| parent | 087c3b638825322414cad5954ccd6a6fc86ccbac (diff) | |
| download | rabbitmq-server-ecd46b56aaf59389b98466dbe9eb6e8a265710d4.tar.gz | |
Rename delegate_{sync,async} to delegate_{call,cast}.
Diffstat (limited to 'src/rabbit_router.erl')
| -rw-r--r-- | src/rabbit_router.erl | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/rabbit_router.erl b/src/rabbit_router.erl index a8cffbdf..8c4da5f3 100644 --- a/src/rabbit_router.erl +++ b/src/rabbit_router.erl @@ -56,12 +56,12 @@ deliver(QPids, Delivery = #delivery{mandatory = false, %% therefore safe to use a fire-and-forget cast here and return %% the QPids - the semantics is preserved. This scales much better %% than the non-immediate case below. - delegate:delegate_async(QPids, + delegate:delegate_cast(QPids, fun(Pid) -> rabbit_amqqueue:deliver(Pid, Delivery) end), {routed, QPids}; deliver(QPids, Delivery) -> - Res = delegate:delegate_sync(QPids, + Res = delegate:delegate_call(QPids, fun(Pid) -> rabbit_amqqueue:deliver(Pid, Delivery) end), {Routed, Handled} = lists:foldl(fun fold_deliveries/2, {false, []}, Res), |