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

PoolExecutorParser is now ThreadPoolTaskExecutorParser, and the IntegrationContextUtils 'createTaskExecutor' method is now 'createThreadPoolTaskExecutor'.

Browse Source
This commit is contained in:
Mark Fisher
2008-11-12 02:17:03 +00:00
parent 4e9d1178da
commit cc51f68993
4 changed files with 5 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
org.springframework.integration/src/main/java/org/springframework/integration/config/xml/ApplicationEventMulticasterParser.java
View File

@@ -57,7 +57,7 @@ public class ApplicationEventMulticasterParser extends AbstractSingleBeanDefinit
builder.addPropertyReference("taskExecutor", taskExecutorRef);
}
else {
TaskExecutor taskExecutor = IntegrationContextUtils.createTaskExecutor(1, 10, 0, "event-multicaster-");
TaskExecutor taskExecutor = IntegrationContextUtils.createThreadPoolTaskExecutor(1, 10, 0, "event-multicaster-");
builder.addPropertyValue("taskExecutor", taskExecutor);
}
builder.addPropertyValue("collectionClass", CopyOnWriteArraySet.class);

4
org.springframework.integration/src/main/java/org/springframework/integration/config/xml/IntegrationNamespaceHandler.java
View File

@@ -77,7 +77,7 @@ public class IntegrationNamespaceHandler implements NamespaceHandler {
}
TaskExecutor taskExecutor = null;
if (!registry.containsBeanDefinition(IntegrationContextUtils.TASK_SCHEDULER_BEAN_NAME)) {
taskExecutor = IntegrationContextUtils.createTaskExecutor(2, 100, 0, "task-scheduler-");
taskExecutor = IntegrationContextUtils.createThreadPoolTaskExecutor(2, 100, 0, "task-scheduler-");
BeanDefinitionBuilder schedulerBuilder = BeanDefinitionBuilder.genericBeanDefinition(SimpleTaskScheduler.class);
schedulerBuilder.addConstructorArgValue(taskExecutor);
BeanDefinitionBuilder errorHandlerBuilder = BeanDefinitionBuilder.genericBeanDefinition(MessagePublishingErrorHandler.class);
@@ -111,7 +111,7 @@ public class IntegrationNamespaceHandler implements NamespaceHandler {
registerBeanDefinitionParser("selector-chain", new SelectorChainParser());
registerBeanDefinitionParser("annotation-config", new AnnotationConfigParser());
registerBeanDefinitionParser("application-event-multicaster", new ApplicationEventMulticasterParser());
registerBeanDefinitionParser("thread-pool-task-executor", new PoolExecutorParser());
registerBeanDefinitionParser("thread-pool-task-executor", new ThreadPoolTaskExecutorParser());
}
}

2
org.springframework.integration/src/main/java/org/springframework/integration/config/xml/PoolExecutorParser.java → org.springframework.integration/src/main/java/org/springframework/integration/config/xml/ThreadPoolTaskExecutorParser.java
View File

@@ -28,7 +28,7 @@ import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
/**
* @author Mark Fisher
*/
public class PoolExecutorParser extends AbstractSimpleBeanDefinitionParser {
public class ThreadPoolTaskExecutorParser extends AbstractSimpleBeanDefinitionParser {
private static final String REJECTION_POLICY_ATTRIBUTE = "rejection-policy";

3
org.springframework.integration/src/main/java/org/springframework/integration/context/IntegrationContextUtils.java
View File

@@ -19,7 +19,6 @@ package org.springframework.integration.context;
import java.util.concurrent.ThreadPoolExecutor.CallerRunsPolicy;
import org.springframework.beans.factory.BeanFactory;
import org.springframework.core.task.TaskExecutor;
import org.springframework.integration.core.MessageChannel;
import org.springframework.integration.scheduling.TaskScheduler;
import org.springframework.scheduling.concurrent.CustomizableThreadFactory;
@@ -62,7 +61,7 @@ public abstract class IntegrationContextUtils {
return (T) bean;
}
public static TaskExecutor createTaskExecutor(int coreSize, int maxSize, int queueCapacity, String threadPrefix) {
public static ThreadPoolTaskExecutor createThreadPoolTaskExecutor(int coreSize, int maxSize, int queueCapacity, String threadPrefix) {
ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
executor.setCorePoolSize(coreSize);
executor.setMaxPoolSize(maxSize);