diff options
| author | Matthias Radestock <matthias@rabbitmq.com> | 2011-03-30 12:11:06 +0100 |
|---|---|---|
| committer | Matthias Radestock <matthias@rabbitmq.com> | 2011-03-30 12:11:06 +0100 |
| commit | 065f2e7596ab1e27669c05c0b0be9469376f6559 (patch) | |
| tree | e6fdb88d65c9881dfbf0635dab1fe5fcc5617aba /src | |
| parent | 091226b7427f84616a76c4f41d235655e6044f61 (diff) | |
| download | rabbitmq-server-git-065f2e7596ab1e27669c05c0b0be9469376f6559.tar.gz | |
cosmetic
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_exchange.erl | 17 |
1 files changed, 7 insertions, 10 deletions
diff --git a/src/rabbit_exchange.erl b/src/rabbit_exchange.erl index 5f2d63f6a1..dfcb05d6a7 100644 --- a/src/rabbit_exchange.erl +++ b/src/rabbit_exchange.erl @@ -84,15 +84,12 @@ -define(INFO_KEYS, [name, type, durable, auto_delete, internal, arguments]). recover() -> - Xs = rabbit_misc:table_fold( - fun (X, Acc) -> - write_exchange(X), - [X | Acc] - end, [], rabbit_durable_exchange), + Xs = rabbit_misc:table_fold(fun (X, Acc) -> store(X), [X | Acc] end, + [], rabbit_durable_exchange), Bs = rabbit_binding:recover(), - recover_with_bindings( - lists:keysort(#binding.source, Bs), - lists:keysort(#exchange.name, Xs), []). + recover_with_bindings(lists:keysort(#binding.source, Bs), + lists:keysort(#exchange.name, Xs), + []). recover_with_bindings([B = #binding{source = XName} | Rest], Xs = [#exchange{name = XName} | _], @@ -121,7 +118,7 @@ declare(XName, Type, Durable, AutoDelete, Internal, Args) -> fun () -> case mnesia:wread({rabbit_exchange, XName}) of [] -> - write_exchange(X), + store(X), ok = case Durable of true -> mnesia:write(rabbit_durable_exchange, X, write); @@ -145,7 +142,7 @@ declare(XName, Type, Durable, AutoDelete, Internal, Args) -> Err end). -write_exchange(X = #exchange{name = Name, type = Type}) -> +store(X = #exchange{name = Name, type = Type}) -> ok = mnesia:write(rabbit_exchange, X, write), case (type_to_module(Type)):serialise_events() of true -> S = #exchange_serial{name = Name, serial = 0}, |