@@ -307,13 +307,14 @@ vhost_update_default_queue_type_undefined(Config) ->
307
307
VHost = <<" update-default_queue_type-with-undefined-test" >>,
308
308
Description = <<" rmqfpas-105 test vhost" >>,
309
309
Tags = [replicate , private ],
310
- DefaultQueueType = quorum ,
310
+ VhostDefaultQueueType = quorum ,
311
+ NodeDefaultQueueType = rabbit_ct_broker_helpers :rpc (Config , 0 , rabbit_queue_type , default_alias , []),
311
312
Trace = false ,
312
313
ActingUser = <<" acting-user" >>,
313
314
try
314
315
? assertMatch (ok , rabbit_ct_broker_helpers :add_vhost (Config , VHost )),
315
316
316
- PutVhostArgs0 = [VHost , Description , Tags , DefaultQueueType , Trace , ActingUser ],
317
+ PutVhostArgs0 = [VHost , Description , Tags , VhostDefaultQueueType , Trace , ActingUser ],
317
318
? assertMatch (ok ,
318
319
rabbit_ct_broker_helpers :rpc (Config , 0 , rabbit_vhost , put_vhost , PutVhostArgs0 )),
319
320
@@ -322,7 +323,7 @@ vhost_update_default_queue_type_undefined(Config) ->
322
323
rabbit_ct_broker_helpers :rpc (Config , 0 , rabbit_vhost , put_vhost , PutVhostArgs1 )),
323
324
324
325
V = rabbit_ct_broker_helpers :rpc (Config , 0 , rabbit_vhost , lookup , [VHost ]),
325
- ? assertMatch (#{default_queue_type := DefaultQueueType }, vhost :get_metadata (V ))
326
+ ? assertMatch (#{default_queue_type := NodeDefaultQueueType }, vhost :get_metadata (V ))
326
327
after
327
328
rabbit_ct_broker_helpers :delete_vhost (Config , VHost )
328
329
end .
0 commit comments