diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2012-06-08 15:16:40 +0100 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2012-06-08 15:16:40 +0100 |
| commit | d22cbc616b4e82b1864bb97e121ddd96d17a14ea (patch) | |
| tree | 74fa36320a4b46298f390b73563e4b650014a888 /deps/rabbitmq_federation/src/rabbit_federation_exchange.erl | |
| parent | 2b4114b1505459e1e23fa64dd0ef7b19d1ce4e0c (diff) | |
| download | rabbitmq-server-git-d22cbc616b4e82b1864bb97e121ddd96d17a14ea.tar.gz | |
Get the tests passing again (TODO: write more tests!). This necessitates a bit of rejigging of interfaces (mostly back closer to where it is on default). Note that the validation test is no longer needed :-)
Diffstat (limited to 'deps/rabbitmq_federation/src/rabbit_federation_exchange.erl')
| -rw-r--r-- | deps/rabbitmq_federation/src/rabbit_federation_exchange.erl | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/deps/rabbitmq_federation/src/rabbit_federation_exchange.erl b/deps/rabbitmq_federation/src/rabbit_federation_exchange.erl index d4dd95203b..0595bc505d 100644 --- a/deps/rabbitmq_federation/src/rabbit_federation_exchange.erl +++ b/deps/rabbitmq_federation/src/rabbit_federation_exchange.erl @@ -91,9 +91,10 @@ federate(X) -> {error, _} -> false end. -maybe_start(X)-> +maybe_start(X = #exchange{name = XName})-> case federate(X) of - true -> ok = rabbit_federation_db:prune_scratch(X), + true -> ok = rabbit_federation_db:prune_scratch( + XName, rabbit_federation_upstream:for(X)), {ok, _} = rabbit_federation_link_sup_sup:start_child(X), ok; false -> ok |