@@ -1754,23 +1754,23 @@ single_active_consumer_priority_test(Config) ->
17541754 ModCalls = [ S || S = {mod_call , rabbit_quorum_queue , update_consumer_handler , _ } <- StateMachineEvents ],
17551755
17561756 % % C1 should be added as single_active
1757- assert_update_consumer_handler_called (C1 , Resource , single_active , lists :nth (1 , ModCalls )),
1757+ assert_update_consumer_handler_called (C1 , Resource , true , single_active , lists :nth (1 , ModCalls )),
17581758 % % C1 should transition to waiting because ...
1759- assert_update_consumer_handler_called (C1 , Resource , waiting , lists :nth (2 , ModCalls )),
1759+ assert_update_consumer_handler_called (C1 , Resource , false , waiting , lists :nth (2 , ModCalls )),
17601760 % % C2 should become single_active
1761- assert_update_consumer_handler_called (C2 , Resource , single_active , lists :nth (3 , ModCalls )),
1761+ assert_update_consumer_handler_called (C2 , Resource , true , single_active , lists :nth (3 , ModCalls )),
17621762 % % C2 should transition as waiting because ...
1763- assert_update_consumer_handler_called (C2 , Resource , waiting , lists :nth (4 , ModCalls )),
1763+ assert_update_consumer_handler_called (C2 , Resource , false , waiting , lists :nth (4 , ModCalls )),
17641764 % % C3 is added as single_active
1765- assert_update_consumer_handler_called (C3 , Resource , single_active , lists :nth (5 , ModCalls )),
1765+ assert_update_consumer_handler_called (C3 , Resource , true , single_active , lists :nth (5 , ModCalls )),
17661766
17671767 ok .
17681768
1769- assert_update_consumer_handler_called (ConsumerId , Resource , UpdatedState , ModCall ) ->
1769+ assert_update_consumer_handler_called (ConsumerId , Resource , IsActive , UpdatedState , ModCall ) ->
17701770 {mod_call ,rabbit_quorum_queue ,update_consumer_handler ,
17711771 [Resource ,
17721772 ConsumerId ,
1773- _ ,_ ,_ ,_ ,UpdatedState ,[]]} = ModCall .
1773+ _ ,_ ,_ ,IsActive ,UpdatedState ,[]]} = ModCall .
17741774
17751775single_active_consumer_priority_cancel_active_test (Config ) ->
17761776 S0 = init (#{name => ? FUNCTION_NAME ,
0 commit comments