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

Remove two now unused functions 

Follow-up to #2868
This commit is contained in:
Michael Klishin 2021-03-05 07:17:06 +03:00
parent af50305d5d
commit 8f2e4edcdf
No known key found for this signature in database
GPG Key ID: E80EDCFA0CDB21EE
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) ->
gen_server2:start_link(?MODULE, Args, [{timeout, infinity}]).
federation_up() ->
is_pid(whereis(rabbit_federation_app)).
init({Upstream, XName}) ->
%% 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

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) ->
QName = amqqueue:get_name(Queue),
case rabbit_amqqueue:lookup(QName) of