File tree 1 file changed +9
-4
lines changed
src/test/java/com/rabbitmq/stream/perf
1 file changed +9
-4
lines changed Original file line number Diff line number Diff line change @@ -79,7 +79,7 @@ static void waitOneSecond() throws InterruptedException {
79
79
}
80
80
81
81
ArgumentsBuilder builder () {
82
- return new ArgumentsBuilder ().stream (s ).rate (100 );
82
+ return new ArgumentsBuilder ().stream (s ).rate (1000 );
83
83
}
84
84
85
85
@ BeforeEach
@@ -348,17 +348,22 @@ void publishConfirmLatencyShouldBeIncludedWhenOptionIsEnabled() throws Exception
348
348
waitOneSecond ();
349
349
run .cancel (true );
350
350
waitRunEnds ();
351
- assertThat (consoleOutput ()).contains ("confirm latency" );
351
+ assertThat (consoleOutput ())
352
+ .contains ("confirm latency" )
353
+ .doesNotContain ("confirm latency 95th 0 ms" );
352
354
}
353
355
354
356
@ Test
355
- void publishConfirmLatencyShouldNotBeIncludedWhenOptionIsDisabled () throws Exception {
357
+ void confirmLatencyShouldBeIncluded () throws Exception {
356
358
Future <?> run = run (builder ());
357
359
waitUntilStreamExists (s );
358
360
waitOneSecond ();
359
361
run .cancel (true );
360
362
waitRunEnds ();
361
- assertThat (consoleOutput ()).doesNotContain ("confirm latency" );
363
+ assertThat (consoleOutput ())
364
+ .contains ("latency 95th" )
365
+ .doesNotContain ("latency 95th 0 ms" )
366
+ .doesNotContain ("confirm latency" );
362
367
}
363
368
364
369
private static HttpResponse httpRequest (String urlString ) throws Exception {
You can’t perform that action at this time.
0 commit comments