Don't federate internal-use queues.

This commit is contained in:
Simon MacMullen 2014-01-13 18:31:57 +00:00
parent b30852b544
commit 49ce187e2a
1 changed files with 8 additions and 1 deletions

View File

@ -63,7 +63,14 @@ policy_changed_local(Q1, Q2) ->
shutdown(Q1),
startup(Q2).
active_for(Q) -> rabbit_federation_upstream:federate(Q).
active_for(Q = #amqqueue{arguments = Args}) ->
case rabbit_misc:table_lookup(Args, <<"x-internal-purpose">>) of
{longstr, _} -> false; %% [0]
_ -> rabbit_federation_upstream:federate(Q)
end.
%% [0] Currently the only "internal purpose" is federation, but I
%% suspect if we introduce another one it will also be for something
%% that doesn't want to be federated.
%% We need to reconsider whether we need to run or pause every time
%% something significant changes in the queue. In theory we don't need