summaryrefslogtreecommitdiff
path: root/src/rabbit_router.erl
diff options
context:
space:
mode:
authorMatthew Sackman <matthew@lshift.net>2010-04-28 15:51:25 +0100
committerMatthew Sackman <matthew@lshift.net>2010-04-28 15:51:25 +0100
commitbd1e95edc964c8c9954e6e254d7a3395039e1c75 (patch)
tree2eccf83c1ccdba1dd9ef02ca334e89fef6bb2a7f /src/rabbit_router.erl
parente5cbbcaf844b4aaea87da0622792b888fda83e97 (diff)
downloadrabbitmq-server-bd1e95edc964c8c9954e6e254d7a3395039e1c75.tar.gz
cosmetics
Diffstat (limited to 'src/rabbit_router.erl')
-rw-r--r--src/rabbit_router.erl8
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}).