summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorMatthias Radestock <matthias@rabbitmq.com>2010-10-11 22:03:55 +0100
committerMatthias Radestock <matthias@rabbitmq.com>2010-10-11 22:03:55 +0100
commitb629aac5ae7840479f1628eaf15d90af7b2ef684 (patch)
tree69cfd75ec6700b8894495ef82113838fc6b4e75e
parentfe9b9a05c79b957bf922eb2b5670629ad4accf60 (diff)
downloadrabbitmq-server-git-b629aac5ae7840479f1628eaf15d90af7b2ef684.tar.gz
cosmetic
-rw-r--r--src/rabbit_router.erl13
1 files changed, 6 insertions, 7 deletions
diff --git a/src/rabbit_router.erl b/src/rabbit_router.erl
index a4ff5ba6e2..39eac07272 100644
--- a/src/rabbit_router.erl
+++ b/src/rabbit_router.erl
@@ -110,10 +110,9 @@ 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)).
+ lists:foldl(fun (QName, QPids) ->
+ case mnesia:dirty_read({rabbit_queue, QName}) of
+ [#amqqueue{pid = QPid}] -> [QPid | QPids];
+ [] -> QPids
+ end
+ end, [], lists:usort(QNames)).