diff options
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_binding.erl | 4 | ||||
| -rw-r--r-- | src/rabbit_exchange.erl | 4 |
2 files changed, 4 insertions, 4 deletions
diff --git a/src/rabbit_binding.erl b/src/rabbit_binding.erl index 557a8f29a4..8c6732f92d 100644 --- a/src/rabbit_binding.erl +++ b/src/rabbit_binding.erl @@ -108,10 +108,6 @@ recover(XNames, QNames) -> end, dict:new(), rabbit_durable_route), rabbit_misc:execute_pre_post_mnesia_tx( fun (Tx) -> - [begin - {ok, X} = rabbit_exchange:lookup(XName), - rabbit_exchange:callback(X, create, [Tx, X]) - end|| XName <- XNames], dict:map(fun (XName, Bindings) -> {ok, X} = rabbit_exchange:lookup(XName), rabbit_exchange:callback(X, add_bindings, diff --git a/src/rabbit_exchange.erl b/src/rabbit_exchange.erl index acbc6c9060..b39fe32ca7 100644 --- a/src/rabbit_exchange.erl +++ b/src/rabbit_exchange.erl @@ -91,6 +91,10 @@ recover() -> [_] -> Acc end end, [], rabbit_durable_exchange), + rabbit_misc:execute_pre_post_mnesia_tx( + fun (Tx) -> + [rabbit_exchange:callback(X, create, [Tx, X]) || X <- Xs] + end), [XName || #exchange{name = XName} <- Xs]. callback(#exchange{type = XType}, Fun, Args) -> |