From a10d90887efdd9eb0f8a588a8a8c94b15d1eb0aa Mon Sep 17 00:00:00 2001 From: Matthias Radestock Date: Fri, 8 Apr 2011 12:55:42 +0100 Subject: cosmetic --- src/rabbit_binding.erl | 2 +- src/rabbit_exchange.erl | 12 ++++++------ 2 files changed, 7 insertions(+), 7 deletions(-) diff --git a/src/rabbit_binding.erl b/src/rabbit_binding.erl index c9106711..ca7be59a 100644 --- a/src/rabbit_binding.erl +++ b/src/rabbit_binding.erl @@ -109,11 +109,11 @@ recover(XNames, QNames) -> mnesia:read({rabbit_durable_route, B}) =/= [] end, fun (R = #route{binding = B = #binding{source = Src}}, Tx) -> - {ok, X} = rabbit_exchange:lookup(Src), case Tx of true -> ok = sync_transient_binding(R, fun mnesia:write/3); false -> ok end, + {ok, X} = rabbit_exchange:lookup(Src), rabbit_exchange:callback(X, add_binding, [Tx, X, B]) end, rabbit_durable_route), diff --git a/src/rabbit_exchange.erl b/src/rabbit_exchange.erl index a74f9d28..42111773 100644 --- a/src/rabbit_exchange.erl +++ b/src/rabbit_exchange.erl @@ -87,12 +87,12 @@ recover() -> fun (#exchange{name = XName}) -> mnesia:read({rabbit_exchange, XName}) =:= [] end, - fun (X, Tx) -> case Tx of - true -> ok = mnesia:write(rabbit_exchange, - X, write); - false -> ok - end, - rabbit_exchange:callback(X, create, [Tx, X]) + fun (X, Tx) -> + case Tx of + true -> ok = mnesia:write(rabbit_exchange, X, write); + false -> ok + end, + rabbit_exchange:callback(X, create, [Tx, X]) end, rabbit_durable_exchange), [XName || #exchange{name = XName} <- Xs]. -- cgit v1.2.1