SpringCloud/spring-cloud-task
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Let TaskBatchExecutionListener implement TaskExecutionListener

Browse Source
This commit is contained in:
Henning Poettker
2022-11-22 03:20:55 +01:00
committed by Glenn Renfro
parent acdf72b771
commit 92c3d948fd
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
spring-cloud-task-batch/src/main/java/org/springframework/cloud/task/batch/listener/TaskBatchExecutionListener.java
View File

@@ -21,7 +21,7 @@ import org.apache.commons.logging.LogFactory;
import org.springframework.batch.core.JobExecution;
import org.springframework.batch.core.JobExecutionListener;
import org.springframework.cloud.task.listener.annotation.BeforeTask;
import org.springframework.cloud.task.listener.TaskExecutionListener;
import org.springframework.cloud.task.repository.TaskExecution;
import org.springframework.core.Ordered;
import org.springframework.util.Assert;
@@ -32,13 +32,13 @@ import org.springframework.util.Assert;
*
* @author Michael Minella
*/
public class TaskBatchExecutionListener implements JobExecutionListener, Ordered {
public class TaskBatchExecutionListener implements JobExecutionListener, Ordered, TaskExecutionListener {
private static final Log logger = LogFactory.getLog(TaskBatchExecutionListener.class);
private TaskExecution taskExecution;
private TaskBatchDao taskBatchDao;
private final TaskBatchDao taskBatchDao;
/**
* @param taskBatchDao dao used to persist the relationship. Must not be null
@@ -49,7 +49,7 @@ public class TaskBatchExecutionListener implements JobExecutionListener, Ordered
this.taskBatchDao = taskBatchDao;
}
@BeforeTask
@Override
public void onTaskStartup(TaskExecution taskExecution) {
this.taskExecution = taskExecution;
}