diff --git a/spring-cloud-task-core/src/main/java/org/springframework/cloud/task/configuration/SimpleTaskAutoConfiguration.java b/spring-cloud-task-core/src/main/java/org/springframework/cloud/task/configuration/SimpleTaskAutoConfiguration.java index b8c5ec7e..c53a8c94 100644 --- a/spring-cloud-task-core/src/main/java/org/springframework/cloud/task/configuration/SimpleTaskAutoConfiguration.java +++ b/spring-cloud-task-core/src/main/java/org/springframework/cloud/task/configuration/SimpleTaskAutoConfiguration.java @@ -84,6 +84,7 @@ public class SimpleTaskAutoConfiguration { return this.taskRepository; } + @Bean public PlatformTransactionManager springCloudTaskTransactionManager() { return this.platformTransactionManager; diff --git a/spring-cloud-task-core/src/main/java/org/springframework/cloud/task/configuration/SingleInstanceTaskListener.java b/spring-cloud-task-core/src/main/java/org/springframework/cloud/task/configuration/SingleInstanceTaskListener.java index ad8f00ef..03d2e4fb 100644 --- a/spring-cloud-task-core/src/main/java/org/springframework/cloud/task/configuration/SingleInstanceTaskListener.java +++ b/spring-cloud-task-core/src/main/java/org/springframework/cloud/task/configuration/SingleInstanceTaskListener.java @@ -27,6 +27,7 @@ import org.springframework.cloud.task.listener.annotation.BeforeTask; import org.springframework.cloud.task.listener.annotation.FailedTask; import org.springframework.cloud.task.repository.TaskExecution; import org.springframework.cloud.task.repository.TaskNameResolver; +import org.springframework.context.ApplicationContext; import org.springframework.context.ApplicationEvent; import org.springframework.context.ApplicationEventPublisher; import org.springframework.context.ApplicationListener; @@ -37,6 +38,7 @@ import org.springframework.integration.leader.event.OnFailedToAcquireMutexEvent; import org.springframework.integration.leader.event.OnGrantedEvent; import org.springframework.integration.support.leader.LockRegistryLeaderInitiator; import org.springframework.integration.support.locks.LockRegistry; +import org.springframework.transaction.PlatformTransactionManager; /** * When spring.cloud.task.single-instance-enabled is set to true this listener will create @@ -67,24 +69,33 @@ public class SingleInstanceTaskListener implements ApplicationListener