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 | 979415ea8bea18f071895dbd8312f1e290f95c55 (patch) | |
| tree | 0c3f550c1f29cc3a2f26aeae2d3361876b1ef218 | |
| parent | b865db3a6d3981342d1bc475b17174ebd47eef6d (diff) | |
| download | rabbitmq-server-git-979415ea8bea18f071895dbd8312f1e290f95c55.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 985099a87d..96d7dbe7b3 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, |