summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorSimon MacMullen <simon@rabbitmq.com>2011-07-06 16:00:48 +0100
committerSimon MacMullen <simon@rabbitmq.com>2011-07-06 16:00:48 +0100
commitfc88a5e37bcd0eb4c805d0b74a0b23cb1d3f89dd (patch)
tree4e2552c3e3217769faa2e31ecca89e7a7d7437bb
parent365b62015bc138195fd389919e6572b55d786b6a (diff)
downloadrabbitmq-server-fc88a5e37bcd0eb4c805d0b74a0b23cb1d3f89dd.tar.gz
One last tweak.
-rw-r--r--src/rabbit_binding.erl5
1 files changed, 2 insertions, 3 deletions
diff --git a/src/rabbit_binding.erl b/src/rabbit_binding.erl
index 11887944..b88e6977 100644
--- a/src/rabbit_binding.erl
+++ b/src/rabbit_binding.erl
@@ -114,9 +114,8 @@ recover_semi_durable_route(R = #route{binding = B}, ToRecover) ->
{ok, X} = rabbit_exchange:lookup(Src),
rabbit_misc:execute_mnesia_transaction(
fun () ->
- case mnesia:match_object(
- rabbit_semi_durable_route, R, read) =/= [] andalso
- sets:is_element(Dst, ToRecover) of
+ Rs = mnesia:match_object(rabbit_semi_durable_route, R, read),
+ case Rs =/= [] andalso sets:is_element(Dst, ToRecover) of
false -> no_recover;
true -> ok = sync_transient_route(R, fun mnesia:write/3),
rabbit_exchange:serial(X)