diff options
author | Matthias Radestock <matthias@rabbitmq.com> | 2012-09-21 15:30:11 +0100 |
---|---|---|
committer | Matthias Radestock <matthias@rabbitmq.com> | 2012-09-21 15:30:11 +0100 |
commit | aca8685a571472041fdd34e6ff5f7f22e86da932 (patch) | |
tree | 1a2c386525e5fec528087e0820c55e2ad4ea2d89 | |
parent | 9724e6f4f5ce034e892eadff1073e893e99b11c0 (diff) | |
download | rabbitmq-server-aca8685a571472041fdd34e6ff5f7f22e86da932.tar.gz |
refactor for clarity (I think)
-rw-r--r-- | src/rabbit_binding.erl | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/src/rabbit_binding.erl b/src/rabbit_binding.erl index 2e462354..0d23f716 100644 --- a/src/rabbit_binding.erl +++ b/src/rabbit_binding.erl @@ -169,9 +169,9 @@ add(Binding, InnerFun) -> add(Src, Dst, B) -> [SrcDurable, DstDurable] = [durable(E) || E <- [Src, Dst]], - case (not (SrcDurable andalso DstDurable) orelse - mnesia:read({rabbit_durable_route, B}) =:= []) of - true -> ok = sync_route(#route{binding = B}, SrcDurable, DstDurable, + case (SrcDurable andalso DstDurable andalso + mnesia:read({rabbit_durable_route, B}) =/= []) of + false -> ok = sync_route(#route{binding = B}, SrcDurable, DstDurable, fun mnesia:write/3), x_callback(transaction, Src, add_binding, B), Serial = rabbit_exchange:serial(Src), @@ -179,7 +179,7 @@ add(Src, Dst, B) -> x_callback(Serial, Src, add_binding, B), ok = rabbit_event:notify(binding_created, info(B)) end; - false -> rabbit_misc:const({error, binding_not_found}) + true -> rabbit_misc:const({error, binding_not_found}) end. remove(Binding) -> remove(Binding, fun (_Src, _Dst) -> ok end). |