diff options
author | Matthias Radestock <matthias@rabbitmq.com> | 2010-10-11 22:05:09 +0100 |
---|---|---|
committer | Matthias Radestock <matthias@rabbitmq.com> | 2010-10-11 22:05:09 +0100 |
commit | a70e57f8f65434a331270836e3c46c49fd078919 (patch) | |
tree | b14a6b8b8eb9831b403dd6271fb561fc463a4b67 | |
parent | bd43b942e85d73431f112119ecdb2090556bcb86 (diff) | |
parent | dbc8de7405cc6554c143f88691e8b47b2a7d5a59 (diff) | |
download | rabbitmq-server-a70e57f8f65434a331270836e3c46c49fd078919.tar.gz |
merge default into bug21377
-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 f337eda3..00df1ce1 100644 --- a/src/rabbit_router.erl +++ b/src/rabbit_router.erl @@ -114,10 +114,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, [], QNames). + lists:foldl(fun (QName, QPids) -> + case mnesia:dirty_read({rabbit_queue, QName}) of + [#amqqueue{pid = QPid}] -> [QPid | QPids]; + [] -> QPids + end + end, [], QNames). |