pre.7

Author: kjnilsson

deps/rabbit/src/rabbit_fifo_client.erl

@@ -844,9 +844,9 @@ handle_delivery(_QName, _Leader, {delivery, Tag, [_ | _] = IdMsgs},
     MsgIntIds = [Id || {Id, _} <- IdMsgs],
     {State1, Deliveries} = return(Tag, MsgIntIds, State0),
     {ok, State1, Deliveries};
-handle_delivery(QName, Leader, {delivery, Tag, ReadState, Msgs},
+handle_delivery(QName, Leader, {delivery, Tag, ReadPlan, Msgs},
                 #state{cached_segments = Cached0} = State) ->
-    {MsgIds, Cached} = rabbit_fifo:exec_read(Cached0, ReadState, Msgs),
+    {MsgIds, Cached} = rabbit_fifo:exec_read(Cached0, ReadPlan, Msgs),
     handle_delivery(QName, Leader, {delivery, Tag, MsgIds},
                     State#state{cached_segments = Cached}).
 

rabbitmq-components.mk

@@ -50,7 +50,7 @@ dep_khepri = hex 0.16.0
 dep_khepri_mnesia_migration = hex 0.7.1
 dep_osiris = git https://github.com/rabbitmq/osiris v1.8.5
 dep_prometheus = hex 4.11.0
-dep_ra = hex 2.16.0-pre.7
+dep_ra = hex 2.16.0-pre.8
 dep_ranch = hex 2.1.0
 dep_recon = hex 2.5.6
 dep_redbug = hex 2.0.7