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 | c2384ddaef8a5fe1a6d3745efe12725bf44b5be9 (patch) | |
| tree | 2eccf83c1ccdba1dd9ef02ca334e89fef6bb2a7f /src | |
| parent | 95a04cb4b51a8760845900b44ef780c24e5b7a27 (diff) | |
| download | rabbitmq-server-git-c2384ddaef8a5fe1a6d3745efe12725bf44b5be9.tar.gz | |
cosmetics
Diffstat (limited to 'src')
| -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 444be4b267..ea16bb401c 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}). |