Skip to content

Commit b6a9bf0

Browse files
Karl NilssonKarl Nilsson
authored andcommitted
QQ: force delete followers after leader has terminated.
In some mixed machine version scenarios some followers will never apply the poison pill command so we may as well force delete them just in case.
1 parent dd3fad2 commit b6a9bf0

File tree

1 file changed

+3
-0
lines changed

1 file changed

+3
-0
lines changed

deps/rabbit/src/rabbit_quorum_queue.erl

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -736,6 +736,9 @@ delete(Q, _IfUnused, _IfEmpty, ActingUser) when ?amqqueue_is_quorum(Q) ->
736736
MRef = erlang:monitor(process, Leader),
737737
receive
738738
{'DOWN', MRef, process, _, _} ->
739+
%% leader is down,
740+
%% force delete remaining members
741+
ok = force_delete_queue(lists:delete(Leader, Servers)),
739742
ok
740743
after Timeout ->
741744
erlang:demonitor(MRef, [flush]),

0 commit comments

Comments
 (0)