diff options
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}). |