diff options
| author | Simon MacMullen <simon@lshift.net> | 2010-04-12 13:52:57 +0100 |
|---|---|---|
| committer | Simon MacMullen <simon@lshift.net> | 2010-04-12 13:52:57 +0100 |
| commit | c76f074ad679220dac767aa4000dba0e217b9fdd (patch) | |
| tree | d405c6b696f8238ef6a003e9f3d50d8b9c089dbf /src/rabbit_router.erl | |
| parent | 1bc29585c63c95708a7bc11fdb9a4b0ee3f3387d (diff) | |
| download | rabbitmq-server-c76f074ad679220dac767aa4000dba0e217b9fdd.tar.gz | |
Clean up exported function names.
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 8c4da5f3..5fd5715b 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_cast(QPids, + delegate:cast(QPids, fun(Pid) -> rabbit_amqqueue:deliver(Pid, Delivery) end), {routed, QPids}; deliver(QPids, Delivery) -> - Res = delegate:delegate_call(QPids, + Res = delegate:call(QPids, fun(Pid) -> rabbit_amqqueue:deliver(Pid, Delivery) end), {Routed, Handled} = lists:foldl(fun fold_deliveries/2, {false, []}, Res), |