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

Merge pull request #2869 from rabbitmq/mk-remove-unused-federation-is-up 

Remove two now unused functions
This commit is contained in:
Michael Klishin 2021-03-05 07:19:11 +03:00 committed by GitHub
parent af50305d5d 8f2e4edcdf
commit 34af2a784b
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 0 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
deps/rabbitmq_federation/src/rabbit_federation_exchange_link.erl vendored
View File

@ -62,9 +62,6 @@ list_routing_keys(XN) -> call(XN, list_routing_keys).
start_link(Args) -> start_link(Args) ->
gen_server2:start_link(?MODULE, Args, [{timeout, infinity}]). gen_server2:start_link(?MODULE, Args, [{timeout, infinity}]).
federation_up() ->
is_pid(whereis(rabbit_federation_app)).
init({Upstream, XName}) -> init({Upstream, XName}) ->
%% If we are starting up due to a policy change then it's possible %% If we are starting up due to a policy change then it's possible
%% for the exchange to have been deleted before we got here, in which %% for the exchange to have been deleted before we got here, in which

3
deps/rabbitmq_federation/src/rabbit_federation_queue_link.erl vendored
View File

@ -55,9 +55,6 @@ q(QName) ->
%%---------------------------------------------------------------------------- %%----------------------------------------------------------------------------
federation_up() ->
is_pid(whereis(rabbit_federation_app)).
init({Upstream, Queue}) when ?is_amqqueue(Queue) -> init({Upstream, Queue}) when ?is_amqqueue(Queue) ->
QName = amqqueue:get_name(Queue), QName = amqqueue:get_name(Queue),
case rabbit_amqqueue:lookup(QName) of case rabbit_amqqueue:lookup(QName) of