try

Author: kjnilsson

deps/rabbit/src/rabbit_channel.erl

@@ -564,8 +564,10 @@ prioritise_cast(Msg, _Len, _State) ->
     case Msg of
         {confirm,            _MsgSeqNos, _QPid} -> 5;
         {reject_publish,     _MsgSeqNos, _QPid} -> 5;
-        {queue_event, _, {confirm,            _MsgSeqNos, _QPid}} -> 5;
+        % {queue_event, _, {confirm,            _MsgSeqNos, _QPid}} -> 5;
         {queue_event, _, {reject_publish,     _MsgSeqNos, _QPid}} -> 5;
+        {method, #'basic.ack'{}, _Content, _Flow} -> 5;
+        % {queue_event, _, {delivery, _, _}} -> 0;
         _                                       -> 0
     end.
 

deps/rabbit/src/rabbit_fifo.erl

@@ -2064,8 +2064,8 @@ delivery_effect(ConsumerKey, Msgs,
                 #?STATE{cfg = #cfg{resource = _QR}} = State) ->
     {CTag, CPid} = consumer_id(ConsumerKey, State),
     {RaftIdxs, _Num} = lists:foldr(fun ({_, ?MSG(I, _)}, {Acc, N}) ->
-                                          {[I | Acc], N+1}
-                                  end, {[], 0}, Msgs),
+                                           {[I | Acc], N+1}
+                                   end, {[], 0}, Msgs),
     {log_ext, RaftIdxs,
      fun
          % (Commands)