@@ -912,7 +912,8 @@ overview(#?STATE{consumers = Cons,
912912 in_memory_message_bytes => 0 , % % backwards compat
913913 num_in_memory_ready_messages => 0 , % % backwards compat
914914 release_cursor_enqueue_counter => EnqCount ,
915- smallest_raft_index => smallest_raft_index (State )
915+ smallest_raft_index => smallest_raft_index (State ),
916+ smallest_raft_index_overview => smallest_raft_index_overview (State )
916917 },
917918 DlxOverview = rabbit_fifo_dlx :overview (DlxState ),
918919 maps :merge (maps :merge (Overview , DlxOverview ), SacOverview ).
@@ -2826,6 +2827,13 @@ smallest_raft_index(#?STATE{messages = Messages,
28262827 SmallestRaIdx = rabbit_fifo_index :smallest (Indexes ),
28272828 min (min (SmallestDlxRaIdx , SmallestMsgsRaIdx ), SmallestRaIdx ).
28282829
2830+ smallest_raft_index_overview (#? STATE {messages = Messages ,
2831+ ra_indexes = Indexes ,
2832+ dlx = DlxState }) ->
2833+ #{message => rabbit_fifo_q :get_lowest_index (Messages ),
2834+ checked_out => rabbit_fifo_index :smallest (Indexes ),
2835+ dlx => rabbit_fifo_dlx :smallest_raft_index (DlxState )}.
2836+
28292837make_requeue (ConsumerKey , Notify , [{MsgId , Idx , Header , Msg }], Acc ) ->
28302838 lists :reverse ([{append ,
28312839 # requeue {consumer_key = ConsumerKey ,
0 commit comments