diff options
| author | Ben Hood <0x6e6562@gmail.com> | 2008-12-23 21:15:00 +0000 |
|---|---|---|
| committer | Ben Hood <0x6e6562@gmail.com> | 2008-12-23 21:15:00 +0000 |
| commit | 4be2257979970f5b697d1e4402ca0bd6bd3ae691 (patch) | |
| tree | a2e7ee5d7a7446698ef693f976eabc9cf5a29744 /src | |
| parent | 48abf8ddb13bf6cfd7907dc63073b345549d568f (diff) | |
| parent | 42360d6d969d641262f157896ce95017e4bc0e83 (diff) | |
| download | rabbitmq-server-git-4be2257979970f5b697d1e4402ca0bd6bd3ae691.tar.gz | |
Merged 20061 into default
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_exchange.erl | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/src/rabbit_exchange.erl b/src/rabbit_exchange.erl index c8069e08ef..925c335cee 100644 --- a/src/rabbit_exchange.erl +++ b/src/rabbit_exchange.erl @@ -268,8 +268,10 @@ route_internal(#exchange{name = Name}, RoutingKey) -> lookup_qpids(Queues) -> sets:fold( fun(Key, Acc) -> - [#amqqueue{pid = QPid}] = mnesia:dirty_read({amqqueue, Key}), - [QPid | Acc] + case mnesia:dirty_read({amqqueue, Key}) of + [#amqqueue{pid = QPid}] -> [QPid | Acc]; + [] -> Acc + end end, [], sets:from_list(Queues)). %% TODO: Should all of the route and binding management not be |