diff options
| author | Matthias Radestock <matthias@rabbitmq.com> | 2010-10-11 22:03:55 +0100 |
|---|---|---|
| committer | Matthias Radestock <matthias@rabbitmq.com> | 2010-10-11 22:03:55 +0100 |
| commit | b629aac5ae7840479f1628eaf15d90af7b2ef684 (patch) | |
| tree | 69cfd75ec6700b8894495ef82113838fc6b4e75e | |
| parent | fe9b9a05c79b957bf922eb2b5670629ad4accf60 (diff) | |
| download | rabbitmq-server-git-b629aac5ae7840479f1628eaf15d90af7b2ef684.tar.gz | |
cosmetic
| -rw-r--r-- | src/rabbit_router.erl | 13 |
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)). |
