diff options
| author | Michael Klishin <michael@clojurewerkz.org> | 2023-05-07 21:31:36 +0400 |
|---|---|---|
| committer | Michael Klishin <michael@clojurewerkz.org> | 2023-05-07 21:31:36 +0400 |
| commit | 013628db15fc9334a6505a629459a2ccc98b2afb (patch) | |
| tree | d5f0c4767615c88b200676832659facd0e00af1c /deps | |
| parent | 3835a137d6b42c9e1bdfb762c6615220b2a5b24c (diff) | |
| download | rabbitmq-server-git-013628db15fc9334a6505a629459a2ccc98b2afb.tar.gz | |
Pass Dialyzer
Diffstat (limited to 'deps')
| -rw-r--r-- | deps/rabbitmq_peer_discovery_common/src/rabbit_peer_discovery_cleanup.erl | 12 |
1 files changed, 5 insertions, 7 deletions
diff --git a/deps/rabbitmq_peer_discovery_common/src/rabbit_peer_discovery_cleanup.erl b/deps/rabbitmq_peer_discovery_common/src/rabbit_peer_discovery_cleanup.erl index a50cc187db..fcfdf7385d 100644 --- a/deps/rabbitmq_peer_discovery_common/src/rabbit_peer_discovery_cleanup.erl +++ b/deps/rabbitmq_peer_discovery_common/src/rabbit_peer_discovery_cleanup.erl @@ -277,13 +277,11 @@ maybe_remove_nodes([Node | Nodes], false) -> ?LOG_WARNING( "Peer discovery: removing unknown node ~ts from the cluster", [Node], #{domain => ?RMQLOG_DOMAIN_PEER_DIS}), - case rabbit_db_cluster:forget_member(Node, false) of - ok -> - ?LOG_WARNING( - "Peer discovery: removing all quorum queue replicas on node ~ts", [Node], - #{domain => ?RMQLOG_DOMAIN_PEER_DIS}), - _ = rabbit_quorum_queue:shrink_all(Node) - end, + _ = rabbit_db_cluster:forget_member(Node, false), + ?LOG_WARNING( + "Peer discovery: removing all quorum queue replicas on node ~ts", [Node], + #{domain => ?RMQLOG_DOMAIN_PEER_DIS}), + _ = rabbit_quorum_queue:shrink_all(Node), maybe_remove_nodes(Nodes, false). %%-------------------------------------------------------------------- |