Spring/spring-integration
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

INT-1747 added SimpleAsyncTaskExecutor to ResubmittingTask

Browse Source
This commit is contained in:
Oleg Zhurakousky
2011-01-20 14:49:47 -05:00
parent 129df10cd6
commit c3ea9d279a
1 changed files with 8 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
spring-integration-mail/src/main/java/org/springframework/integration/mail/ResubmittingTask.java
View File

@@ -22,6 +22,7 @@ import java.util.concurrent.Executor;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.springframework.core.task.SimpleAsyncTaskExecutor;
import org.springframework.scheduling.TaskScheduler;
/**
@@ -35,7 +36,7 @@ class ResubmittingTask implements Runnable {
private final Runnable targetTask;
private final TaskScheduler scheduler;
private final long delay;
private Executor taskExecutor;
private Executor taskExecutor = new SimpleAsyncTaskExecutor();
public ResubmittingTask(Runnable targetTask, TaskScheduler scheduler, long delay) {
this.targetTask = targetTask;
@@ -44,20 +45,15 @@ class ResubmittingTask implements Runnable {
}
public void setTaskExecutor(Executor taskExecutor) {
this.taskExecutor = taskExecutor;
this.taskExecutor = (taskExecutor != null) ? taskExecutor : new SimpleAsyncTaskExecutor();
}
public void run() {
if (taskExecutor != null){
taskExecutor.execute(new Runnable() {
public void run() {
ResubmittingTask.this.invokeTask();
}
});
}
else {
this.invokeTask();
}
taskExecutor.execute(new Runnable() {
public void run() {
ResubmittingTask.this.invokeTask();
}
});
}
private void invokeTask(){