diff options
| author | Matthew Sackman <matthew@rabbitmq.com> | 2011-06-21 14:09:02 +0100 |
|---|---|---|
| committer | Matthew Sackman <matthew@rabbitmq.com> | 2011-06-21 14:09:02 +0100 |
| commit | e7c1d76dca8b4081172d816244eeb18ada5ce98a (patch) | |
| tree | 6c77ffdb454316dd8ec553d8712a201ec9052585 /src/rabbit_router.erl | |
| parent | 20ac2a0c3aef49cadfb48535e8a176ff68f913b4 (diff) | |
| parent | bb9c797422ca474ad295b061525fd54fa007b511 (diff) | |
| download | rabbitmq-server-e7c1d76dca8b4081172d816244eeb18ada5ce98a.tar.gz | |
Merging default into bug23554
Diffstat (limited to 'src/rabbit_router.erl')
| -rw-r--r-- | src/rabbit_router.erl | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/src/rabbit_router.erl b/src/rabbit_router.erl index 8f166672..b1d940d2 100644 --- a/src/rabbit_router.erl +++ b/src/rabbit_router.erl @@ -110,8 +110,10 @@ check_delivery(_ , _ , {_ , Qs}) -> {routed, Qs}. lookup_qpids(QNames) -> lists:foldl(fun (QName, QPids) -> case mnesia:dirty_read({rabbit_queue, QName}) of - [#amqqueue{pid = QPid}] -> [QPid | QPids]; - [] -> QPids + [#amqqueue{pid = QPid, mirror_pids = MPids}] -> + MPids ++ [QPid | QPids]; + [] -> + QPids end end, [], QNames). |