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

Added support for "taskExecutor" on the @Poller annotation. This requires a reference to a TaskExecutor instance resolvable by bean name (INT-409).

Browse Source
This commit is contained in:
Mark Fisher
2008-10-10 14:48:11 +00:00
parent 526f4b25dc
commit 0dfe9ca191
2 changed files with 10 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
org.springframework.integration/src/main/java/org/springframework/integration/annotation/Poller.java
View File

@@ -49,6 +49,8 @@ public @interface Poller {
int maxMessagesPerPoll() default -1;
String taskExecutor() default "";
Transactional transactionAttributes() default @Transactional;
String transactionManager() default "";

8
org.springframework.integration/src/main/java/org/springframework/integration/config/annotation/AnnotationConfigUtils.java
View File

@@ -22,6 +22,7 @@ import java.util.List;
import org.aopalliance.aop.Advice;
import org.springframework.beans.factory.BeanFactory;
import org.springframework.core.task.TaskExecutor;
import org.springframework.integration.annotation.Poller;
import org.springframework.integration.endpoint.AbstractPollingEndpoint;
import org.springframework.integration.scheduling.IntervalTrigger;
@@ -57,6 +58,13 @@ public abstract class AnnotationConfigUtils {
Transactional txAnnotation = pollerAnnotation.transactionAttributes();
endpoint.setTransactionDefinition(parseTransactionAnnotation(txAnnotation));
}
if (StringUtils.hasText(pollerAnnotation.taskExecutor())) {
String taskExecutorRef = pollerAnnotation.taskExecutor();
Assert.isTrue(beanFactory.containsBean(taskExecutorRef),
"failed to resolve taskExecutor reference, no such bean '" + taskExecutorRef + "'");
TaskExecutor taskExecutor = (TaskExecutor) beanFactory.getBean(taskExecutorRef, TaskExecutor.class);
endpoint.setTaskExecutor(taskExecutor);
}
String[] adviceChainArray = pollerAnnotation.adviceChain();
if (adviceChainArray.length > 0) {
List<Advice> adviceChain = new ArrayList<Advice>();