Skip to content

Commit

Permalink
rabbit_quorum_queue_periodic_membership_reconciliation:on_node_down s…
Browse files Browse the repository at this point in the history
…hould be called even with Khepri as db
  • Loading branch information
SimonUnge authored and michaelklishin committed May 4, 2024
1 parent 4d34d39 commit d81d9c1
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion deps/rabbit/src/rabbit_node_monitor.erl
Original file line number Diff line number Diff line change
Expand Up @@ -856,6 +856,7 @@ handle_dead_rabbit(Node, State) ->
%% statements on *one* node, rather than all of them.
ok = rabbit_amqqueue:on_node_down(Node),
ok = rabbit_alarm:on_node_down(Node),
ok = rabbit_quorum_queue_periodic_membership_reconciliation:on_node_down(Node),
State1 = case rabbit_khepri:is_enabled() of
true -> State;
false -> on_node_down_using_mnesia(Node, State)
Expand All @@ -865,7 +866,6 @@ handle_dead_rabbit(Node, State) ->
on_node_down_using_mnesia(Node, State = #state{partitions = Partitions,
autoheal = Autoheal}) ->
ok = rabbit_mnesia:on_node_down(Node),
ok = rabbit_quorum_queue_periodic_membership_reconciliation:on_node_down(Node),
%% If we have been partitioned, and we are now in the only remaining
%% partition, we no longer care about partitions - forget them. Note
%% that we do not attempt to deal with individual (other) partitions
Expand Down

0 comments on commit d81d9c1

Please sign in to comment.