diff options
| author | Matthew Sackman <matthew@lshift.net> | 2010-04-28 15:51:25 +0100 |
|---|---|---|
| committer | Matthew Sackman <matthew@lshift.net> | 2010-04-28 15:51:25 +0100 |
| commit | bd1e95edc964c8c9954e6e254d7a3395039e1c75 (patch) | |
| tree | 2eccf83c1ccdba1dd9ef02ca334e89fef6bb2a7f | |
| parent | e5cbbcaf844b4aaea87da0622792b888fda83e97 (diff) | |
| download | rabbitmq-server-bd1e95edc964c8c9954e6e254d7a3395039e1c75.tar.gz | |
cosmetics
| -rw-r--r-- | src/rabbit_router.erl | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/src/rabbit_router.erl b/src/rabbit_router.erl index 444be4b2..ea16bb40 100644 --- a/src/rabbit_router.erl +++ b/src/rabbit_router.erl @@ -56,13 +56,13 @@ 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:invoke_async(QPids, - fun(Pid) -> rabbit_amqqueue:deliver(Pid, Delivery) end), + delegate:invoke_async( + QPids, fun(Pid) -> rabbit_amqqueue:deliver(Pid, Delivery) end), {routed, QPids}; deliver(QPids, Delivery) -> - Res = delegate:invoke(QPids, - fun(Pid) -> rabbit_amqqueue:deliver(Pid, Delivery) end), + Res = delegate:invoke( + QPids, fun(Pid) -> rabbit_amqqueue:deliver(Pid, Delivery) end), {Routed, Handled} = lists:foldl(fun fold_deliveries/2, {false, []}, Res), check_delivery(Delivery#delivery.mandatory, Delivery#delivery.immediate, {Routed, Handled}). |