diff options
| author | Matthew Sackman <matthew@rabbitmq.com> | 2011-01-20 13:46:52 +0000 |
|---|---|---|
| committer | Matthew Sackman <matthew@rabbitmq.com> | 2011-01-20 13:46:52 +0000 |
| commit | 95ec4db59912849015f9d16209c5b10580a22a68 (patch) | |
| tree | 666c5193708f7282bfd3ef9e2b8564bd5e5b1b72 /src/rabbit_router.erl | |
| parent | a3ff54bc80fbe7cef61edc4a53142204f99f8f38 (diff) | |
| parent | dfdc73cb66700ade923ed2ed8a6ef475c9bf67d0 (diff) | |
| download | rabbitmq-server-95ec4db59912849015f9d16209c5b10580a22a68.tar.gz | |
Merging default into bug23554 (epic debitrot)
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 692d2473..309e0e6e 100644 --- a/src/rabbit_router.erl +++ b/src/rabbit_router.erl @@ -102,7 +102,9 @@ 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). |