You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2012/09/07 11:30:55 UTC
svn commit: r1381951 - /camel/trunk/camel-core/src/main/java/org/apache/camel/impl/DefaultExecutorServiceManager.java

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);