diff options
| author | Ben Hood <0x6e6562@gmail.com> | 2008-10-07 12:08:31 +0100 |
|---|---|---|
| committer | Ben Hood <0x6e6562@gmail.com> | 2008-10-07 12:08:31 +0100 |
| commit | 6e6830164138c024bb6db3d3a76b1e6d16c79c39 (patch) | |
| tree | 2b7a636088dd11353b06e44885d1266fb540bfc3 /src | |
| parent | 0ba0739aa3517924326840190a0806af68f9694e (diff) | |
| download | rabbitmq-server-git-6e6830164138c024bb6db3d3a76b1e6d16c79c39.tar.gz | |
Brought forwards delete function into loop to avoid delete_object wildcard issue when it is fixed in OTP
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_exchange.erl | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/src/rabbit_exchange.erl b/src/rabbit_exchange.erl index 946202ff0c..39505c5ae7 100644 --- a/src/rabbit_exchange.erl +++ b/src/rabbit_exchange.erl @@ -259,13 +259,13 @@ delete_bindings_for_queue(QueueName) -> indexed_delete(Match, ForwardsDeleteFun, ReverseDeleteFun) -> lists:foreach(fun(Route) -> - ok = ReverseDeleteFun(reverse_route(Route)) - end, mnesia:match_object(Match)), - ForwardsDeleteFun(Match). + ok = ReverseDeleteFun(reverse_route(Route)), + ok = ForwardsDeleteFun(Route) + end, mnesia:match_object(Match)). -delete_forward_routes(Match) -> - ok = mnesia:delete_object(Match), - ok = mnesia:delete_object(durable_routes, Match, write). +delete_forward_routes(Route) -> + ok = mnesia:delete_object(Route), + ok = mnesia:delete_object(durable_routes, Route, write). exchanges_for_queue(QueueName) -> MatchHead = #reverse_route{reverse_binding = |