1515 */
1616package org .springframework .batch .core .job .builder ;
1717
18- import java .util .Arrays ;
19-
20- import javax .sql .DataSource ;
21-
22- import static org .junit .jupiter .api .Assertions .assertEquals ;
23-
18+ import org .apache .commons .logging .Log ;
19+ import org .apache .commons .logging .LogFactory ;
20+ import org .junit .jupiter .api .Assertions ;
2421import org .junit .jupiter .api .BeforeEach ;
2522import org .junit .jupiter .api .Test ;
2623import org .springframework .batch .core .*;
4037import org .springframework .batch .core .step .StepSupport ;
4138import org .springframework .batch .core .step .builder .StepBuilder ;
4239import org .springframework .batch .item .support .ListItemReader ;
40+ import org .springframework .batch .repeat .RepeatStatus ;
41+ import org .springframework .batch .support .transaction .ResourcelessTransactionManager ;
42+ import org .springframework .beans .factory .annotation .Qualifier ;
4343import org .springframework .beans .factory .annotation .Value ;
4444import org .springframework .context .ApplicationContext ;
4545import org .springframework .context .annotation .AnnotationConfigApplicationContext ;
5454
5555import javax .sql .DataSource ;
5656import java .util .Arrays ;
57+ import java .util .concurrent .CountDownLatch ;
58+ import java .util .concurrent .TimeUnit ;
5759
58- import static org .junit .Assert .assertTrue ;
5960import static org .junit .jupiter .api .Assertions .assertEquals ;
6061
6162/**
6263 * @author Dave Syer
6364 * @author Mahmoud Ben Hassine
65+ * @author Fabrice Bibonne
6466 */
6567class FlowJobBuilderTests {
6668
@@ -374,7 +376,7 @@ void testStepNamesMustBeUniqueWithinFlowDefinition() throws JobInstanceAlreadyCo
374376 new JobParametersBuilder ().addLong ("random" , 2L )
375377 .addString ("stepTwo.name" , JobConfigurationForStepNameUnique .SHARED_NAME )
376378 .toJobParameters ());
377- assertTrue (jobExecution .getAllFailureExceptions ()
379+ Assertions . assertTrue (jobExecution .getAllFailureExceptions ()
378380 .stream ()
379381 .map (Object ::getClass )
380382 .anyMatch (AlreadyUsedStepNameException .class ::equals ));
@@ -383,7 +385,7 @@ void testStepNamesMustBeUniqueWithinFlowDefinition() throws JobInstanceAlreadyCo
383385 new JobParametersBuilder ().addLong ("random" , 1L )
384386 .addString ("stepTwo.name" , JobConfigurationForStepNameUnique .SHARED_NAME )
385387 .toJobParameters ());
386- assertTrue (jobExecution .getAllFailureExceptions ()
388+ Assertions . assertTrue (jobExecution .getAllFailureExceptions ()
387389 .stream ()
388390 .map (Object ::getClass )
389391 .anyMatch (AlreadyUsedStepNameException .class ::equals ));
0 commit comments