diff options
| author | Matthias Radestock <matthias@rabbitmq.com> | 2010-09-27 21:53:18 +0100 |
|---|---|---|
| committer | Matthias Radestock <matthias@rabbitmq.com> | 2010-09-27 21:53:18 +0100 |
| commit | da43ca9e9e0b3881b1ba11137b2dcb157c19a789 (patch) | |
| tree | 9aa9379a84727d539eee8a6c5d65321ecdaa8f4d | |
| parent | 483d59916f24f3f35a6ec8663e5fc9c8248e06ee (diff) | |
| download | rabbitmq-server-da43ca9e9e0b3881b1ba11137b2dcb157c19a789.tar.gz | |
minor refactor
| -rw-r--r-- | src/rabbit_binding.erl | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/src/rabbit_binding.erl b/src/rabbit_binding.erl index f7ec3b27..71b9960b 100644 --- a/src/rabbit_binding.erl +++ b/src/rabbit_binding.erl @@ -123,7 +123,7 @@ add(Binding, InnerFun) -> ok -> case mnesia:read({rabbit_route, B}) of [] -> ok = sync_binding( - B, are_endpoints_durable(Src, Dst), + B, all_durable([Src, Dst]), fun mnesia:write/3), {new, Src, B}; [_] -> {existing, Src, B} @@ -153,7 +153,7 @@ remove(Binding, InnerFun) -> case InnerFun(Src, Dst) of ok -> ok = sync_binding( - B, are_endpoints_durable(Src, Dst), + B, all_durable([Src, Dst]), fun mnesia:delete_object/3), Deleted = rabbit_exchange:maybe_auto_delete(Src), @@ -254,10 +254,10 @@ remove_transient_for_destination(DstName) -> %%---------------------------------------------------------------------------- -are_endpoints_durable(#exchange{durable = A}, #amqqueue{durable = B}) -> - A andalso B; -are_endpoints_durable(#exchange{durable = A}, #exchange{durable = B}) -> - A andalso B. +all_durable(Resources) -> + lists:all(fun (#exchange{durable = D}) -> D; + (#amqqueue{durable = D}) -> D + end, Resources). binding_action(Binding = #binding{source = SrcName, destination = DstName, |