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

Creating the TaskScheduler as a bean definition within the context in MessageBusParser instead of instantiating with a constructor call.

Browse Source
This commit is contained in:
Mark Fisher
2008-10-16 01:03:52 +00:00
parent 0f52b88851
commit 2f009b607b
1 changed files with 8 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
org.springframework.integration/src/main/java/org/springframework/integration/config/xml/MessageBusParser.java
View File

@@ -111,7 +111,14 @@ public class MessageBusParser extends AbstractSimpleBeanDefinitionParser {
}
else {
taskExecutor = this.createTaskExecutor(100, "message-bus-");
builder.addPropertyValue("taskScheduler", new SimpleTaskScheduler(taskExecutor));
BeanDefinitionBuilder schedulerBuilder = BeanDefinitionBuilder.genericBeanDefinition(SimpleTaskScheduler.class);
schedulerBuilder.addConstructorArgValue(taskExecutor);
// TODO: define bean name as a constant elsewhere
String TASK_SCHEDULER_BEAN_NAME = "taskScheduler";
BeanDefinitionHolder schedulerHolder = new BeanDefinitionHolder(
schedulerBuilder.getBeanDefinition(), TASK_SCHEDULER_BEAN_NAME);
BeanDefinitionReaderUtils.registerBeanDefinition(schedulerHolder, parserContext.getRegistry());
builder.addPropertyReference("taskScheduler", TASK_SCHEDULER_BEAN_NAME);
}
if ("true".equals(element.getAttribute(ASYNC_EVENT_MULTICASTER_ATTRIBUTE).toLowerCase())) {
if (taskExecutor == null) {