fix

Author: kjnilsson

deps/rabbit/src/rabbit_fifo_client.erl

@@ -728,8 +728,6 @@ handle_ra_event(QName, _, timeout, #state{cfg = #cfg{servers = Servers},
                                           pending = Pending} = State0) ->
     case find_leader(Servers) of
         undefined ->
-            ?LOG_DEBUG("~ts: ~s Pending applied Timeout, no leader found, num pend ~b ",
-                       [rabbit_misc:rs(QName), ?MODULE, maps:size(Pending)]),
             %% still no leader, set the timer again
             {ok, set_timer(QName, State0), []};
         Leader ->
@@ -812,12 +810,16 @@ seq_applied({Seq, Response},
             {Corrs, Actions0, #state{} = State0}) ->
     %% sequences aren't guaranteed to be applied in order as enqueues are
     %% low priority commands and may be overtaken by others with a normal priority.
+    %%
+    %% if the response is 'not_enqueued' we need to still keep the pending
+    %% command for a later resend
     {Actions, State} = maybe_add_action(Response, Actions0, State0),
     case maps:take(Seq, State#state.pending) of
-        {{undefined, _}, Pending} ->
+        {{undefined, _}, Pending}
+          when Response =/= not_enqueued ->
             {Corrs, Actions, State#state{pending = Pending}};
         {{Corr, _}, Pending}
-          when Response /= not_enqueued ->
+          when Response =/= not_enqueued ->
             {[Corr | Corrs], Actions, State#state{pending = Pending}};
         _ ->
             {Corrs, Actions, State}