summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorMatthias Radestock <matthias@rabbitmq.com>2010-10-11 22:05:09 +0100
committerMatthias Radestock <matthias@rabbitmq.com>2010-10-11 22:05:09 +0100
commita70e57f8f65434a331270836e3c46c49fd078919 (patch)
treeb14a6b8b8eb9831b403dd6271fb561fc463a4b67
parentbd43b942e85d73431f112119ecdb2090556bcb86 (diff)
parentdbc8de7405cc6554c143f88691e8b47b2a7d5a59 (diff)
downloadrabbitmq-server-a70e57f8f65434a331270836e3c46c49fd078919.tar.gz
merge default into bug21377
-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 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).