@@ -482,53 +482,50 @@ queues_enable_totals_test(Config) ->
482482 Publish (<<" foo" >>),
483483
484484 Fun = fun () ->
485- length (rabbit_ct_broker_helpers :rpc (Config , 0 , ets , tab2list ,
486- [queue_coarse_metrics ])) == 2
485+ Queues = http_get (Config , " /queues/%2F" ),
486+ Queue = http_get (Config , " /queues/%2F/foo" ),
487+
488+ Node = rabbit_ct_broker_helpers :get_node_config (Config , 0 , nodename ),
489+ NodeBin = atom_to_binary (Node , utf8 ),
490+ assert_list ([#{name => <<" baz" >>,
491+ vhost => <<" /" >>,
492+ durable => true ,
493+ auto_delete => false ,
494+ exclusive => false ,
495+ arguments => #{'x-queue-type' => <<" classic" >>},
496+ node => NodeBin ,
497+ messages => 1 ,
498+ messages_ready => 1 ,
499+ messages_unacknowledged => 0 },
500+ #{name => <<" foo" >>,
501+ vhost => <<" /" >>,
502+ durable => true ,
503+ auto_delete => false ,
504+ exclusive => null ,
505+ arguments => #{'x-queue-type' => <<" quorum" >>},
506+ leader => NodeBin ,
507+ messages => 2 ,
508+ messages_ready => 2 ,
509+ messages_unacknowledged => 0 ,
510+ members => [NodeBin ]}], Queues ),
511+ assert_item (#{name => <<" foo" >>,
512+ vhost => <<" /" >>,
513+ durable => true ,
514+ auto_delete => false ,
515+ exclusive => null ,
516+ arguments => #{'x-queue-type' => <<" quorum" >>},
517+ leader => NodeBin ,
518+ messages => 2 ,
519+ messages_ready => 2 ,
520+ messages_unacknowledged => 0 ,
521+ members => [NodeBin ]}, Queue ),
522+
523+ ? assert (not maps :is_key (message_stats , Queue )),
524+ ? assert (not maps :is_key (messages_details , Queue )),
525+ ? assert (not maps :is_key (reductions_details , Queue )),
526+ true
487527 end ,
488528 await_condition (Fun ),
489-
490- Queues = http_get (Config , " /queues/%2F" ),
491- Queue = http_get (Config , " /queues/%2F/foo" ),
492-
493- Node = rabbit_ct_broker_helpers :get_node_config (Config , 0 , nodename ),
494- NodeBin = atom_to_binary (Node , utf8 ),
495- assert_list ([#{name => <<" baz" >>,
496- vhost => <<" /" >>,
497- durable => true ,
498- auto_delete => false ,
499- exclusive => false ,
500- arguments => #{'x-queue-type' => <<" classic" >>},
501- node => NodeBin ,
502- messages => 1 ,
503- messages_ready => 1 ,
504- messages_unacknowledged => 0 },
505- #{name => <<" foo" >>,
506- vhost => <<" /" >>,
507- durable => true ,
508- auto_delete => false ,
509- exclusive => null ,
510- arguments => #{'x-queue-type' => <<" quorum" >>},
511- leader => NodeBin ,
512- messages => 2 ,
513- messages_ready => 2 ,
514- messages_unacknowledged => 0 ,
515- members => [NodeBin ]}], Queues ),
516- assert_item (#{name => <<" foo" >>,
517- vhost => <<" /" >>,
518- durable => true ,
519- auto_delete => false ,
520- exclusive => null ,
521- arguments => #{'x-queue-type' => <<" quorum" >>},
522- leader => NodeBin ,
523- messages => 2 ,
524- messages_ready => 2 ,
525- messages_unacknowledged => 0 ,
526- members => [NodeBin ]}, Queue ),
527-
528- ? assert (not maps :is_key (message_stats , Queue )),
529- ? assert (not maps :is_key (messages_details , Queue )),
530- ? assert (not maps :is_key (reductions_details , Queue )),
531-
532529 http_delete (Config , " /queues/%2F/foo" , {group , '2xx' }),
533530 http_delete (Config , " /queues/%2F/baz" , {group , '2xx' }),
534531 close_connection (Conn ),
0 commit comments