diff --git a/spring-cloud-task-batch/pom.xml b/spring-cloud-task-batch/pom.xml
index 214382d8..9822728b 100644
--- a/spring-cloud-task-batch/pom.xml
+++ b/spring-cloud-task-batch/pom.xml
@@ -73,6 +73,11 @@
org.assertj
assertj-core
+ test
+
+
+ org.springframework.boot
+ spring-boot-test
diff --git a/spring-cloud-task-batch/src/main/java/org/springframework/cloud/task/batch/configuration/TaskBatchAutoConfiguration.java b/spring-cloud-task-batch/src/main/java/org/springframework/cloud/task/batch/configuration/TaskBatchAutoConfiguration.java
index 434c19d7..8167f30e 100644
--- a/spring-cloud-task-batch/src/main/java/org/springframework/cloud/task/batch/configuration/TaskBatchAutoConfiguration.java
+++ b/spring-cloud-task-batch/src/main/java/org/springframework/cloud/task/batch/configuration/TaskBatchAutoConfiguration.java
@@ -56,6 +56,9 @@ public class TaskBatchAutoConfiguration {
@Autowired
private ApplicationContext context;
+ @Autowired
+ private TaskProperties taskProperties;
+
@Bean
public TaskBatchExecutionListenerFactoryBean taskBatchExecutionListener(TaskExplorer taskExplorer) {
TaskConfigurer taskConfigurer = null;
diff --git a/spring-cloud-task-batch/src/test/java/org/springframework/cloud/task/batch/listener/PrefixTests.java b/spring-cloud-task-batch/src/test/java/org/springframework/cloud/task/batch/listener/PrefixTests.java
index 51ee08d3..a187139a 100644
--- a/spring-cloud-task-batch/src/test/java/org/springframework/cloud/task/batch/listener/PrefixTests.java
+++ b/spring-cloud-task-batch/src/test/java/org/springframework/cloud/task/batch/listener/PrefixTests.java
@@ -17,19 +17,15 @@
package org.springframework.cloud.task.batch.listener;
import java.util.Set;
-
import javax.sql.DataSource;
import org.junit.After;
import org.junit.Test;
import org.springframework.batch.core.Job;
-import org.springframework.batch.core.StepContribution;
import org.springframework.batch.core.configuration.annotation.EnableBatchProcessing;
import org.springframework.batch.core.configuration.annotation.JobBuilderFactory;
import org.springframework.batch.core.configuration.annotation.StepBuilderFactory;
-import org.springframework.batch.core.scope.context.ChunkContext;
-import org.springframework.batch.core.step.tasklet.Tasklet;
import org.springframework.batch.repeat.RepeatStatus;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.SpringApplication;
@@ -43,7 +39,6 @@ import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.jdbc.datasource.embedded.EmbeddedDatabaseBuilder;
import org.springframework.jdbc.datasource.embedded.EmbeddedDatabaseType;
-import org.springframework.util.SocketUtils;
import static org.assertj.core.api.Assertions.assertThat;
@@ -52,22 +47,6 @@ import static org.assertj.core.api.Assertions.assertThat;
*/
public class PrefixTests {
- private final static String DATASOURCE_URL;
-
- private final static String DATASOURCE_USER_NAME = "SA";
-
- private final static String DATASOURCE_USER_PASSWORD = "''";
-
- private final static String DATASOURCE_DRIVER_CLASS_NAME = "org.h2.Driver";
-
- private static int randomPort;
-
- static {
- randomPort = SocketUtils.findAvailableTcpPort();
- DATASOURCE_URL = "jdbc:h2:tcp://localhost:" + randomPort + "/mem:dataflow;DB_CLOSE_DELAY=-1;"
- + "DB_CLOSE_ON_EXIT=FALSE";
- }
-
private ConfigurableApplicationContext applicationContext;
@After
@@ -106,13 +85,10 @@ public class PrefixTests {
@Bean
public Job job() {
return jobBuilderFactory.get("job")
- .start(stepBuilderFactory.get("step1").tasklet(new Tasklet() {
- @Override
- public RepeatStatus execute(StepContribution contribution, ChunkContext chunkContext)
- throws Exception {
- System.out.println("Executed");
- return RepeatStatus.FINISHED;
- }
+ .start(stepBuilderFactory.get("step1")
+ .tasklet((contribution, chunkContext) -> {
+ System.out.println("Executed");
+ return RepeatStatus.FINISHED;
}).build())
.build();
}