Verify previous active consumer is waiting

after a higher priority consumer

Author: MarcialRosales

deps/rabbit/test/rabbit_fifo_SUITE.erl

@@ -1728,8 +1728,8 @@ single_active_consumer_priority_test(Config) ->
      %% add a consumer with a higher priority, assert it becomes active
      {CK2, make_checkout(C2, {auto, {simple_prefetch, 1}}, #{priority => 2})},
      ?ASSERT(#rabbit_fifo{consumers = #{CK2 := #consumer{status = up}},
-                          waiting_consumers = [_]}),
-
+                          waiting_consumers = [{CK1, _}]}),
+     
      %% enqueue a message
      {E1Idx , rabbit_fifo:make_enqueue(Pid1, 1, msg1)},
      ?ASSERT(#rabbit_fifo{consumers = #{CK2 := #consumer{next_msg_id = 1,
@@ -1751,8 +1751,11 @@ single_active_consumer_priority_test(Config) ->
                when map_size(Ch) == 0)
 
     ],
-    {_S1, _} = run_log(Config, S0, Entries, fun single_active_invariant/1),
-
+    {#rabbit_fifo{ cfg = #cfg{resource = Resource}}, ModCalls} = run_log(Config, S0, Entries, fun single_active_invariant/1),
+    {mod_call,rabbit_quorum_queue,update_consumer_handler,
+            [Resource,
+            _,
+            false,undefined,undefined,false,waiting,[]]} = lists:nth(3, ModCalls),
     ok.
 
 
@@ -2352,6 +2355,7 @@ run_log(Config, InitState, Entries, Invariant) ->
 run_log(Module, Config, InitState, Entries, Invariant) ->
     lists:foldl(
       fun ({assert, Fun}, {Acc0, Efx0}) ->
+            ct:log("run_log. Efx0 : ~p", [Efx0]),
               _ = Fun(Acc0),
               {Acc0, Efx0};
           ({Idx, E}, {Acc0, Efx0}) ->