diff options
| author | Emile Joubert <emile@rabbitmq.com> | 2010-06-30 14:53:15 +0100 |
|---|---|---|
| committer | Emile Joubert <emile@rabbitmq.com> | 2010-06-30 14:53:15 +0100 |
| commit | 9e896c4f76311cfd2ef935ee8304bffe5bd730f7 (patch) | |
| tree | 2360ef2b4b8a1c1f6fb506cb15933bc3defd584d | |
| parent | 2b1ae05e3a4df0c48f52233bac905fd45efbfb5d (diff) | |
| parent | f9a2b1554f07742c8ff4c8d51f2c61be761db85e (diff) | |
| download | rabbitmq-server-git-9e896c4f76311cfd2ef935ee8304bffe5bd730f7.tar.gz | |
Merged bug22392 into default
| -rw-r--r-- | src/rabbit_router.erl | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/rabbit_router.erl b/src/rabbit_router.erl index 5cd15a9462..75196bc0d4 100644 --- a/src/rabbit_router.erl +++ b/src/rabbit_router.erl @@ -90,13 +90,13 @@ match_routing_key(Name, RoutingKey) -> lookup_qpids(mnesia:dirty_select(rabbit_route, [{MatchHead, [], ['$1']}])). lookup_qpids(Queues) -> - sets:fold( + lists:foldl( fun (Key, Acc) -> case mnesia:dirty_read({rabbit_queue, Key}) of [#amqqueue{pid = QPid}] -> [QPid | Acc]; [] -> Acc end - end, [], sets:from_list(Queues)). + end, [], lists:usort(Queues)). %%-------------------------------------------------------------------- |