diff options
| author | Matthew Sackman <matthew@lshift.net> | 2010-02-19 16:17:51 +0000 |
|---|---|---|
| committer | Matthew Sackman <matthew@lshift.net> | 2010-02-19 16:17:51 +0000 |
| commit | 81884f39b9333553e7790832c0f4d729e417e910 (patch) | |
| tree | 794f017e71f826872f71085be7f8d211c9bf1950 | |
| parent | 952d6fcee0a38e2ece3aae4323d5b870bf72c585 (diff) | |
| download | rabbitmq-server-git-81884f39b9333553e7790832c0f4d729e417e910.tar.gz | |
Cosmetics
| -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 151101315c..b2b365ad43 100644 --- a/src/rabbit_exchange.erl +++ b/src/rabbit_exchange.erl @@ -118,9 +118,9 @@ recover_with_bindings(Bs, Exs) -> lists:keysort(#binding.exchange_name, Bs), lists:keysort(#exchange.name, Exs), []). -recover_with_bindings([B = #binding{exchange_name = N} | Rest], +recover_with_bindings([B = #binding{exchange_name = Name} | Rest], Xs = [#exchange{name = Name} | _], - Bindings) when N =:= Name -> + Bindings) -> recover_with_bindings(Rest, Xs, [B | Bindings]); recover_with_bindings(Bs, [X = #exchange{type = Type} | Xs], Bindings) -> (type_to_module(Type)):recover(X, Bindings), @@ -304,7 +304,7 @@ delete_queue_bindings(QueueName, FwdDeleteFun) -> none, [], []), fun () -> lists:foreach( - fun ({{auto_deleted, X = #exchange{ type = Type}}, Bs}) -> + fun ({{auto_deleted, X = #exchange{ type = Type }}, Bs}) -> Module = type_to_module(Type), [Module:delete_binding(X, B) || B <- Bs], Module:delete(X, []); @@ -319,9 +319,9 @@ delete_queue_bindings(QueueName, FwdDeleteFun) -> %% cleanup_deleted_queue_bindings1) works properly. cleanup_deleted_queue_bindings([], ExchangeName, Bindings, Acc) -> cleanup_deleted_queue_bindings1(ExchangeName, Bindings, Acc); -cleanup_deleted_queue_bindings([B = #binding{exchange_name = N} | Rest], - ExchangeName, Bindings, Acc) - when N =:= ExchangeName -> +cleanup_deleted_queue_bindings( + [B = #binding{exchange_name = ExchangeName} | Rest], + ExchangeName, Bindings, Acc) -> cleanup_deleted_queue_bindings(Rest, ExchangeName, [B | Bindings], Acc); cleanup_deleted_queue_bindings([B = #binding{exchange_name = N} | Rest], ExchangeName, Bindings, Acc) -> |