diff options
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_fifo.erl | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/src/rabbit_fifo.erl b/src/rabbit_fifo.erl index 5e3de3ba96..536d544e87 100644 --- a/src/rabbit_fifo.erl +++ b/src/rabbit_fifo.erl @@ -574,8 +574,9 @@ state_enter(eol, #?MODULE{enqueuers = Enqs, [{send_msg, P, eol, ra_event} || P <- maps:keys(maps:merge(Enqs, AllConsumers))] ++ [{mod_call, rabbit_quorum_queue, file_handle_release_reservation, []}]; -state_enter(_, #?MODULE{cfg = #cfg{resource = _Resource} }) -> - [{mod_call, rabbit_quorum_queue, file_handle_other_reservation, []}]; +state_enter(State, #?MODULE{cfg = #cfg{resource = _Resource}}) when State =/= leader -> + FHReservation = {mod_call, rabbit_quorum_queue, file_handle_other_reservation, []}, + [FHReservation]; state_enter(_, _) -> %% catch all as not handling all states []. |