@@ -170,7 +170,7 @@ all_tests_4() ->
170
170
init_per_suite (Config0 ) ->
171
171
rabbit_ct_helpers :log_environment (),
172
172
Config = rabbit_ct_helpers :merge_app_env (
173
- Config0 , {rabbit , [{stream_tick_interval , 1000 },
173
+ Config0 , {rabbit , [{stream_tick_interval , 256 },
174
174
{log , [{file , [{level , debug }]}]}]}),
175
175
rabbit_ct_helpers :run_setup_steps (Config ).
176
176
@@ -436,7 +436,11 @@ declare_queue(Config) ->
436
436
declare (Config , Server , Q , [{<<" x-queue-type" >>, longstr , <<" stream" >>}])),
437
437
438
438
% % Test declare an existing queue
439
- ? assertEqual ({'queue.declare_ok' , Q , 0 , 0 },
439
+ % % there is a very brief race condition in the osiris counter updates that could
440
+ % % cause the message count to be reported as 1 temporarily after a new stream
441
+ % % creation. Hence to avoid flaking we don't match on the messages counter
442
+ % % here
443
+ ? assertMatch ({'queue.declare_ok' , Q , _ , 0 },
440
444
declare (Config , Server , Q , [{<<" x-queue-type" >>, longstr , <<" stream" >>}])),
441
445
442
446
? assertMatch ([_ ], find_queue_info (Config , [])),
0 commit comments