@@ -3476,14 +3476,14 @@ reclaim_memory_with_wrong_queue_type(Config) ->
34763476 % % legacy, special case for classic queues
34773477 ? assertMatch ({error , classic_queue_not_supported },
34783478 rabbit_ct_broker_helpers :rpc (Config , 0 , rabbit_quorum_queue ,
3479- reclaim_memory , [<<" /" >>, CQ ])),
3479+ reclaim_memory , [rabbit_misc : queue_resource ( <<" /" >>, CQ ) ])),
34803480 SQ = ? config (alt_queue_name , Config ),
34813481 ? assertEqual ({'queue.declare_ok' , SQ , 0 , 0 },
34823482 declare (Ch , SQ , [{<<" x-queue-type" >>, longstr , <<" stream" >>}])),
34833483 % % all other (future) queue types get the same error
34843484 ? assertMatch ({error , not_quorum_queue },
34853485 rabbit_ct_broker_helpers :rpc (Config , 0 , rabbit_quorum_queue ,
3486- reclaim_memory , [<<" /" >>, SQ ])),
3486+ reclaim_memory , [rabbit_misc : queue_resource ( <<" /" >>, SQ ) ])),
34873487 ok .
34883488
34893489queue_length_limit_drop_head (Config ) ->
@@ -3703,7 +3703,7 @@ status(Config) ->
37033703 T2 /= <<>> andalso
37043704 T3 /= <<>>,
37053705 rabbit_ct_broker_helpers :rpc (Config , 0 , rabbit_quorum_queue ,
3706- status , [<<" /" >>, QQ ])),
3706+ status , [rabbit_misc : queue_resource ( <<" /" >>, QQ ) ])),
37073707 wait_for_messages (Config , [[QQ , <<" 2" >>, <<" 2" >>, <<" 0" >>]]),
37083708 ok .
37093709
0 commit comments