diff options
| author | Matthias Radestock <matthias@rabbitmq.com> | 2011-04-08 12:55:42 +0100 |
|---|---|---|
| committer | Matthias Radestock <matthias@rabbitmq.com> | 2011-04-08 12:55:42 +0100 |
| commit | a10d90887efdd9eb0f8a588a8a8c94b15d1eb0aa (patch) | |
| tree | 7b4bf5ba7e4fbac1788f4e9833a00ae28c97c07f | |
| parent | b3eb94ab9da72a897860109e80591b10e3fa4f08 (diff) | |
| download | rabbitmq-server-bug24006.tar.gz | |
cosmeticbug24006
| -rw-r--r-- | src/rabbit_binding.erl | 2 | ||||
| -rw-r--r-- | 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]. |