diff options
| author | Matthias Radestock <matthias@lshift.net> | 2008-10-12 11:51:01 +0100 |
|---|---|---|
| committer | Matthias Radestock <matthias@lshift.net> | 2008-10-12 11:51:01 +0100 |
| commit | 9b415e6b132dbaac13da3e54e9a709898cd08a6f (patch) | |
| tree | 0c3f550c1f29cc3a2f26aeae2d3361876b1ef218 | |
| parent | 3d991a0312c1c3a2196840a6c1168925184475f4 (diff) | |
| download | rabbitmq-server-9b415e6b132dbaac13da3e54e9a709898cd08a6f.tar.gz | |
refactoring: never construct reverse routes/bindings directly
| -rw-r--r-- | src/rabbit_exchange.erl | 13 |
1 files changed, 7 insertions, 6 deletions
diff --git a/src/rabbit_exchange.erl b/src/rabbit_exchange.erl index 985099a8..96d7dbe7 100644 --- a/src/rabbit_exchange.erl +++ b/src/rabbit_exchange.erl @@ -254,12 +254,13 @@ delete_forward_routes(Route) -> ok = mnesia:delete_object(durable_routes, Route, write). exchanges_for_queue(QueueName) -> - MatchHead = #reverse_route{reverse_binding = - #reverse_binding{exchange_name = '$1', - queue_name = QueueName, - key = '_'}}, - sets:to_list(sets:from_list( - mnesia:select(reverse_route, [{MatchHead, [], ['$1']}]))). + MatchHead = reverse_route( + #route{binding = #binding{exchange_name = '$1', + queue_name = QueueName, + key = '_'}}), + sets:to_list( + sets:from_list( + mnesia:select(reverse_route, [{MatchHead, [], ['$1']}]))). has_bindings(ExchangeName) -> MatchHead = #route{binding = #binding{exchange_name = ExchangeName, |