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 | 2c82d25fa6ed321ec1a3859f227034ae9e861499 (patch) | |
| tree | 4e2552c3e3217769faa2e31ecca89e7a7d7437bb /src | |
| parent | 91b651a2c2120efd91816aaee16a1ba2b84e72e1 (diff) | |
| download | rabbitmq-server-git-2c82d25fa6ed321ec1a3859f227034ae9e861499.tar.gz | |
One last tweak.
Diffstat (limited to 'src')
| -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 118879441b..b88e697730 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) |