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 | 0d6d3736383e8e6189088c3c9d03c3f17f015de4 (patch) | |
| tree | 2360ef2b4b8a1c1f6fb506cb15933bc3defd584d | |
| parent | 5663d3ae116cb80992be20d68c33363df442da8c (diff) | |
| parent | eb538fe4426b87938f3150cd6421a91b96887b6f (diff) | |
| download | rabbitmq-server-0d6d3736383e8e6189088c3c9d03c3f17f015de4.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 5cd15a94..75196bc0 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)). %%-------------------------------------------------------------------- |