summaryrefslogtreecommitdiff
path: root/src/rabbit_router.erl
diff options
context:
space:
mode:
authorMatthias Radestock <matthias@rabbitmq.com>2010-10-02 03:12:47 +0100
committerMatthias Radestock <matthias@rabbitmq.com>2010-10-02 03:12:47 +0100
commitf4c642ab2985c94531e0794658e56336965edf09 (patch)
tree1e296d8976d3efd69de572fce492512f323903fd /src/rabbit_router.erl
parent0aa36d41b30e68582de75436d029ccf9b8a62509 (diff)
downloadrabbitmq-server-f4c642ab2985c94531e0794658e56336965edf09.tar.gz
cosmetics and some minor refactoring
Diffstat (limited to 'src/rabbit_router.erl')
-rw-r--r--src/rabbit_router.erl19
1 files changed, 9 insertions, 10 deletions
diff --git a/src/rabbit_router.erl b/src/rabbit_router.erl
index 707698b0..a1a341a9 100644
--- a/src/rabbit_router.erl
+++ b/src/rabbit_router.erl
@@ -70,16 +70,15 @@ deliver(QPids, Delivery = #delivery{mandatory = false,
QPids, fun (Pid) -> rabbit_amqqueue:deliver(Pid, Delivery) end),
{routed, QPids};
-deliver(QPids, Delivery) ->
- {Success, _} =
- delegate:invoke(QPids,
- fun (Pid) ->
- rabbit_amqqueue:deliver(Pid, Delivery)
- end),
- {Routed, Handled} =
- lists:foldl(fun fold_deliveries/2, {false, []}, Success),
- case check_delivery(Delivery#delivery.mandatory, Delivery#delivery.immediate,
- {Routed, Handled}) of
+deliver(QPids, Delivery = #delivery{mandatory = Mandatory,
+ immediate = Immediate}) ->
+ {Success, _} = delegate:invoke(
+ QPids, fun (Pid) ->
+ rabbit_amqqueue:deliver(Pid, Delivery)
+ end),
+ case check_delivery(Mandatory, Immediate,
+ lists:foldl(fun fold_deliveries/2,
+ {false, []}, Success)) of
{routed, Qs} -> {routed, Qs};
O -> O
end.