diff options
| author | Michael Klishin <michael@clojurewerkz.org> | 2021-03-05 07:17:06 +0300 |
|---|---|---|
| committer | Michael Klishin <michael@clojurewerkz.org> | 2021-03-05 07:17:06 +0300 |
| commit | 8f2e4edcdfa1071fbda08742e2ee83dbd78b1184 (patch) | |
| tree | 76bda6c3745096cf6126d44547a65eed2e944135 | |
| parent | af50305d5dab9ee6c8be230114e2e8be7ff5e546 (diff) | |
| download | rabbitmq-server-git-8f2e4edcdfa1071fbda08742e2ee83dbd78b1184.tar.gz | |
Remove two now unused functions
Follow-up to #2868
| -rw-r--r-- | deps/rabbitmq_federation/src/rabbit_federation_exchange_link.erl | 3 | ||||
| -rw-r--r-- | deps/rabbitmq_federation/src/rabbit_federation_queue_link.erl | 3 |
2 files changed, 0 insertions, 6 deletions
diff --git a/deps/rabbitmq_federation/src/rabbit_federation_exchange_link.erl b/deps/rabbitmq_federation/src/rabbit_federation_exchange_link.erl index dba68e751c..e3bfecd386 100644 --- a/deps/rabbitmq_federation/src/rabbit_federation_exchange_link.erl +++ b/deps/rabbitmq_federation/src/rabbit_federation_exchange_link.erl @@ -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 diff --git a/deps/rabbitmq_federation/src/rabbit_federation_queue_link.erl b/deps/rabbitmq_federation/src/rabbit_federation_queue_link.erl index c0f5b738f8..768e83c992 100644 --- a/deps/rabbitmq_federation/src/rabbit_federation_queue_link.erl +++ b/deps/rabbitmq_federation/src/rabbit_federation_queue_link.erl @@ -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 |