summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorMatthias Radestock <matthias@rabbitmq.com>2010-10-11 21:53:32 +0100
committerMatthias Radestock <matthias@rabbitmq.com>2010-10-11 21:53:32 +0100
commitfe9b9a05c79b957bf922eb2b5670629ad4accf60 (patch)
treefbf4c1473b65b31f83c9fc88cef5357e14763764
parent9c60db6b5eaf9d036d89f70c4a1b9c041e81ab30 (diff)
downloadrabbitmq-server-git-fe9b9a05c79b957bf922eb2b5670629ad4accf60.tar.gz
cosmetic
-rw-r--r--src/rabbit_router.erl18
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)).