root
/
rabbitmq-server
mirror of https://github.com/rabbitmq/rabbitmq-server.git
1
0
Fork 0
Code Issues Actions Packages Projects Releases Wiki Activity

Don't federate default exchange eben if policy says so. Also avoid all internal exchanges, not just of our upstream type.

This commit is contained in:
Simon MacMullen 2012-05-18 11:42:00 +01:00
parent 6437b2c66f
commit 37ee22b39d
1 changed files with 9 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
deps/rabbitmq_federation/src/rabbit_federation_exchange.erl vendored
View File

@ -74,7 +74,15 @@ policy_changed(none, OldX, NewX) ->
%%----------------------------------------------------------------------------
federate(#exchange{type = 'x-federation-upstream'}) ->
%% Don't federate default exchange, we can't bind to it
federate(#exchange{name = #resource{name = <<"">>}}) ->
false;
%% Don't federate any of our intermediate exchanges. Note that we use
%% internal=true since older brokers may not declare
%% x-federation-upstream on us. Also other internal exchanges should
%% probably not be federated.
federate(#exchange{internal = true}) ->
false;
federate(X) ->