diff options
| author | Matthias Radestock <matthias@rabbitmq.com> | 2010-10-11 21:53:32 +0100 |
|---|---|---|
| committer | Matthias Radestock <matthias@rabbitmq.com> | 2010-10-11 21:53:32 +0100 |
| commit | fe9b9a05c79b957bf922eb2b5670629ad4accf60 (patch) | |
| tree | fbf4c1473b65b31f83c9fc88cef5357e14763764 | |
| parent | 9c60db6b5eaf9d036d89f70c4a1b9c041e81ab30 (diff) | |
| download | rabbitmq-server-git-fe9b9a05c79b957bf922eb2b5670629ad4accf60.tar.gz | |
cosmetic
| -rw-r--r-- | src/rabbit_router.erl | 18 |
1 files changed, 9 insertions, 9 deletions
diff --git a/src/rabbit_router.erl b/src/rabbit_router.erl index bd57f73726..a4ff5ba6e2 100644 --- a/src/rabbit_router.erl +++ b/src/rabbit_router.erl @@ -99,15 +99,6 @@ match_routing_key(Name, RoutingKey) -> _ = '_'}}, lookup_qpids(mnesia:dirty_select(rabbit_route, [{MatchHead, [], ['$1']}])). -lookup_qpids(Queues) -> - lists:foldl( - fun (Key, Acc) -> - case mnesia:dirty_read({rabbit_queue, Key}) of - [#amqqueue{pid = QPid}] -> [QPid | Acc]; - [] -> Acc - end - end, [], lists:usort(Queues)). - %%-------------------------------------------------------------------- fold_deliveries({Pid, true},{_, Handled}) -> {true, [Pid|Handled]}; @@ -117,3 +108,12 @@ fold_deliveries({_, false},{_, Handled}) -> {true, Handled}. check_delivery(true, _ , {false, []}) -> {unroutable, []}; check_delivery(_ , true, {_ , []}) -> {not_delivered, []}; check_delivery(_ , _ , {_ , Qs}) -> {routed, Qs}. + +lookup_qpids(QNames) -> + lists:foldl( + fun (Key, Acc) -> + case mnesia:dirty_read({rabbit_queue, Key}) of + [#amqqueue{pid = QPid}] -> [QPid | Acc]; + [] -> Acc + end + end, [], lists:usort(QNames)). |
