diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2011-07-06 16:00:48 +0100 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2011-07-06 16:00:48 +0100 |
| commit | fc88a5e37bcd0eb4c805d0b74a0b23cb1d3f89dd (patch) | |
| tree | 4e2552c3e3217769faa2e31ecca89e7a7d7437bb | |
| parent | 365b62015bc138195fd389919e6572b55d786b6a (diff) | |
| download | rabbitmq-server-fc88a5e37bcd0eb4c805d0b74a0b23cb1d3f89dd.tar.gz | |
One last tweak.
| -rw-r--r-- | src/rabbit_binding.erl | 5 |
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) |