Author: davsclaus
Date: Fri Sep 7 09:30:55 2012
New Revision: 1381951
URL: http://svn.apache.org/viewvc?rev=1381951&view=rev
Log:
Polished
Modified:
camel/trunk/camel-core/src/main/java/org/apache/camel/impl/DefaultExecutorServiceManager.java
Modified:
camel/trunk/camel-core/src/main/java/org/apache/camel/impl/DefaultExecutorServiceManager.java
URL:
http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/impl/DefaultExecutorServiceManager.java?rev=1381951&r1=1381950&r2=1381951&view=diff
==============================================================================
---
camel/trunk/camel-core/src/main/java/org/apache/camel/impl/DefaultExecutorServiceManager.java
(original)
+++
camel/trunk/camel-core/src/main/java/org/apache/camel/impl/DefaultExecutorServiceManager.java
Fri Sep 7 09:30:55 2012
@@ -62,21 +62,21 @@ public class DefaultExecutorServiceManag
private long shutdownAwaitTermination = 10000;
private String defaultThreadPoolProfileId = "defaultThreadPoolProfile";
private final Map<String, ThreadPoolProfile> threadPoolProfiles = new
HashMap<String, ThreadPoolProfile>();
- private ThreadPoolProfile builtIndefaultProfile;
+ private ThreadPoolProfile defaultProfile;
public DefaultExecutorServiceManager(CamelContext camelContext) {
this.camelContext = camelContext;
- builtIndefaultProfile = new
ThreadPoolProfile(defaultThreadPoolProfileId);
- builtIndefaultProfile.setDefaultProfile(true);
- builtIndefaultProfile.setPoolSize(10);
- builtIndefaultProfile.setMaxPoolSize(20);
- builtIndefaultProfile.setKeepAliveTime(60L);
- builtIndefaultProfile.setTimeUnit(TimeUnit.SECONDS);
- builtIndefaultProfile.setMaxQueueSize(1000);
-
builtIndefaultProfile.setRejectedPolicy(ThreadPoolRejectedPolicy.CallerRuns);
+ defaultProfile = new ThreadPoolProfile(defaultThreadPoolProfileId);
+ defaultProfile.setDefaultProfile(true);
+ defaultProfile.setPoolSize(10);
+ defaultProfile.setMaxPoolSize(20);
+ defaultProfile.setKeepAliveTime(60L);
+ defaultProfile.setTimeUnit(TimeUnit.SECONDS);
+ defaultProfile.setMaxQueueSize(1000);
+ defaultProfile.setRejectedPolicy(ThreadPoolRejectedPolicy.CallerRuns);
- registerThreadPoolProfile(builtIndefaultProfile);
+ registerThreadPoolProfile(defaultProfile);
}
@Override
@@ -109,7 +109,7 @@ public class DefaultExecutorServiceManag
@Override
public void setDefaultThreadPoolProfile(ThreadPoolProfile
defaultThreadPoolProfile) {
threadPoolProfiles.remove(defaultThreadPoolProfileId);
- defaultThreadPoolProfile.addDefaults(builtIndefaultProfile);
+ defaultThreadPoolProfile.addDefaults(defaultProfile);
LOG.info("Using custom DefaultThreadPoolProfile: " +
defaultThreadPoolProfile);