diff options
author | Matthias Radestock <matthias@rabbitmq.com> | 2010-10-02 03:12:47 +0100 |
---|---|---|
committer | Matthias Radestock <matthias@rabbitmq.com> | 2010-10-02 03:12:47 +0100 |
commit | f4c642ab2985c94531e0794658e56336965edf09 (patch) | |
tree | 1e296d8976d3efd69de572fce492512f323903fd /src/rabbit_router.erl | |
parent | 0aa36d41b30e68582de75436d029ccf9b8a62509 (diff) | |
download | rabbitmq-server-f4c642ab2985c94531e0794658e56336965edf09.tar.gz |
cosmetics and some minor refactoring
Diffstat (limited to 'src/rabbit_router.erl')
-rw-r--r-- | src/rabbit_router.erl | 19 |
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. |