diff options
| author | Michael Klishin <michael@clojurewerkz.org> | 2021-03-03 22:45:09 +0300 |
|---|---|---|
| committer | Michael Klishin <michael@clojurewerkz.org> | 2021-03-04 04:06:41 +0300 |
| commit | be11d6087ddcd18239be1f1bb2be0bfd33ba8921 (patch) | |
| tree | 2f19810dbee729e0496366226f7ea4e78c9a32ab | |
| parent | ad47eba2fac2db66938280255ef2e05e0662f0e1 (diff) | |
| download | rabbitmq-server-git-be11d6087ddcd18239be1f1bb2be0bfd33ba8921.tar.gz | |
Synchronize federation_up/0 logic for both link types
| -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, 3 insertions, 3 deletions
diff --git a/deps/rabbitmq_federation/src/rabbit_federation_exchange_link.erl b/deps/rabbitmq_federation/src/rabbit_federation_exchange_link.erl index 8d2fef4141..2520a972cb 100644 --- a/deps/rabbitmq_federation/src/rabbit_federation_exchange_link.erl +++ b/deps/rabbitmq_federation/src/rabbit_federation_exchange_link.erl @@ -256,7 +256,8 @@ x(XName) -> %%---------------------------------------------------------------------------- -federation_up() -> is_pid(whereis(rabbit_federation_app)). +federation_up() -> + is_pid(whereis(rabbit_federation_app)). handle_command({add_binding, Binding}, State) -> add_binding(Binding, State); diff --git a/deps/rabbitmq_federation/src/rabbit_federation_queue_link.erl b/deps/rabbitmq_federation/src/rabbit_federation_queue_link.erl index 5dbf78f26b..17a2c0a178 100644 --- a/deps/rabbitmq_federation/src/rabbit_federation_queue_link.erl +++ b/deps/rabbitmq_federation/src/rabbit_federation_queue_link.erl @@ -54,8 +54,7 @@ q(QName) -> end. federation_up() -> - proplists:is_defined(rabbitmq_federation, - application:which_applications(infinity)). + is_pid(whereis(rabbit_federation_app)). %%---------------------------------------------------------------------------- |