camel-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From davscl...@apache.org
Subject svn commit: r798057 - in /camel/trunk/camel-core/src/main/java/org/apache/camel: impl/ model/ processor/
Date Mon, 27 Jul 2009 07:31:58 GMT
Author: davsclaus
Date: Mon Jul 27 07:31:57 2009
New Revision: 798057

URL: http://svn.apache.org/viewvc?rev=798057&view=rev
Log:
CAMEL-1855: aligned core thread pool size to 10 as default in Camel.

Modified:
    camel/trunk/camel-core/src/main/java/org/apache/camel/impl/DefaultComponent.java
    camel/trunk/camel-core/src/main/java/org/apache/camel/impl/DefaultEndpoint.java
    camel/trunk/camel-core/src/main/java/org/apache/camel/impl/DefaultProducerTemplate.java
    camel/trunk/camel-core/src/main/java/org/apache/camel/impl/ScheduledPollConsumer.java
    camel/trunk/camel-core/src/main/java/org/apache/camel/model/ThreadsDefinition.java
    camel/trunk/camel-core/src/main/java/org/apache/camel/processor/MulticastProcessor.java
    camel/trunk/camel-core/src/main/java/org/apache/camel/processor/OnCompletionProcessor.java
    camel/trunk/camel-core/src/main/java/org/apache/camel/processor/ThreadsProcessor.java
    camel/trunk/camel-core/src/main/java/org/apache/camel/processor/WireTapProcessor.java

Modified: camel/trunk/camel-core/src/main/java/org/apache/camel/impl/DefaultComponent.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/impl/DefaultComponent.java?rev=798057&r1=798056&r2=798057&view=diff
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/impl/DefaultComponent.java (original)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/impl/DefaultComponent.java Mon Jul
27 07:31:57 2009
@@ -44,7 +44,7 @@
 public abstract class DefaultComponent extends ServiceSupport implements Component {
     private static final transient Log LOG = LogFactory.getLog(DefaultComponent.class);
 
-    private static final int DEFAULT_THREADPOOL_SIZE = 5;
+    private static final int DEFAULT_THREADPOOL_SIZE = 10;
     private CamelContext camelContext;
     private ExecutorService executorService;
 

Modified: camel/trunk/camel-core/src/main/java/org/apache/camel/impl/DefaultEndpoint.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/impl/DefaultEndpoint.java?rev=798057&r1=798056&r2=798057&view=diff
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/impl/DefaultEndpoint.java (original)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/impl/DefaultEndpoint.java Mon Jul
27 07:31:57 2009
@@ -38,7 +38,7 @@
  * @version $Revision$
  */
 public abstract class DefaultEndpoint implements Endpoint, CamelContextAware {
-    private static final int DEFAULT_THREADPOOL_SIZE = 5;
+    private static final int DEFAULT_THREADPOOL_SIZE = 10;
 
     private String endpointUri;
     private CamelContext camelContext;

Modified: camel/trunk/camel-core/src/main/java/org/apache/camel/impl/DefaultProducerTemplate.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/impl/DefaultProducerTemplate.java?rev=798057&r1=798056&r2=798057&view=diff
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/impl/DefaultProducerTemplate.java
(original)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/impl/DefaultProducerTemplate.java
Mon Jul 27 07:31:57 2009
@@ -44,7 +44,7 @@
  * @version $Revision$
  */
 public class DefaultProducerTemplate extends ServiceSupport implements ProducerTemplate {
-    private static final int DEFAULT_THREADPOOL_SIZE = 5;
+    private static final int DEFAULT_THREADPOOL_SIZE = 10;
     private final CamelContext context;
     private final ProducerCache producerCache;
     private Endpoint defaultEndpoint;

Modified: camel/trunk/camel-core/src/main/java/org/apache/camel/impl/ScheduledPollConsumer.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/impl/ScheduledPollConsumer.java?rev=798057&r1=798056&r2=798057&view=diff
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/impl/ScheduledPollConsumer.java
(original)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/impl/ScheduledPollConsumer.java
Mon Jul 27 07:31:57 2009
@@ -35,6 +35,7 @@
  * @version $Revision$
  */
 public abstract class ScheduledPollConsumer extends DefaultConsumer implements Runnable {
+    private static final int DEFAULT_THREADPOOL_SIZE = 10;
     private static final transient Log LOG = LogFactory.getLog(ScheduledPollConsumer.class);
 
     private final ScheduledExecutorService executor;
@@ -55,7 +56,7 @@
         if (service instanceof ScheduledExecutorService) {
             scheduled = (ScheduledExecutorService) service;
         } else {
-            scheduled = ExecutorServiceHelper.newScheduledThreadPool(5, getEndpoint().getEndpointUri(),
true);
+            scheduled = ExecutorServiceHelper.newScheduledThreadPool(DEFAULT_THREADPOOL_SIZE,
getEndpoint().getEndpointUri(), true);
         }
 
         this.executor = scheduled;

Modified: camel/trunk/camel-core/src/main/java/org/apache/camel/model/ThreadsDefinition.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/model/ThreadsDefinition.java?rev=798057&r1=798056&r2=798057&view=diff
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/model/ThreadsDefinition.java (original)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/model/ThreadsDefinition.java Mon
Jul 27 07:31:57 2009
@@ -54,7 +54,7 @@
             executorService = routeContext.lookup(executorServiceRef, ExecutorService.class);
         }
         if (executorService == null && poolSize != null) {
-            executorService = ExecutorServiceHelper.newScheduledThreadPool(poolSize, "AsyncProcessor",
true);
+            executorService = ExecutorServiceHelper.newScheduledThreadPool(poolSize, "Threads",
true);
         }
         Processor childProcessor = routeContext.createProcessor(this);
 

Modified: camel/trunk/camel-core/src/main/java/org/apache/camel/processor/MulticastProcessor.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/processor/MulticastProcessor.java?rev=798057&r1=798056&r2=798057&view=diff
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/processor/MulticastProcessor.java
(original)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/processor/MulticastProcessor.java
Mon Jul 27 07:31:57 2009
@@ -51,6 +51,7 @@
  */
 public class MulticastProcessor extends ServiceSupport implements Processor, Navigate, Traceable
{
 
+    private static final int DEFAULT_THREADPOOL_SIZE = 10;
     private static final transient Log LOG = LogFactory.getLog(MulticastProcessor.class);
 
     // TODO: Add option to stop if an exception was thrown during processing to break asap
(future task cancel)
@@ -101,7 +102,7 @@
         if (isParallelProcessing()) {
             if (this.executorService == null) {
                 // setup default executor as parallel processing requires an executor
-                this.executorService = ExecutorServiceHelper.newScheduledThreadPool(5, "Multicast",
true);
+                this.executorService = ExecutorServiceHelper.newScheduledThreadPool(DEFAULT_THREADPOOL_SIZE,
"Multicast", true);
             }
         }
     }

Modified: camel/trunk/camel-core/src/main/java/org/apache/camel/processor/OnCompletionProcessor.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/processor/OnCompletionProcessor.java?rev=798057&r1=798056&r2=798057&view=diff
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/processor/OnCompletionProcessor.java
(original)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/processor/OnCompletionProcessor.java
Mon Jul 27 07:31:57 2009
@@ -35,6 +35,7 @@
  */
 public class OnCompletionProcessor extends ServiceSupport implements Processor, Traceable
{
 
+    private static final int DEFAULT_THREADPOOL_SIZE = 10;
     private static final transient Log LOG = LogFactory.getLog(OnCompletionProcessor.class);
     private ExecutorService executorService;
     private Processor processor;
@@ -158,7 +159,7 @@
     }
 
     private ExecutorService createExecutorService() {
-        return ExecutorServiceHelper.newScheduledThreadPool(5, this.toString(), true);
+        return ExecutorServiceHelper.newScheduledThreadPool(DEFAULT_THREADPOOL_SIZE, this.toString(),
true);
     }
 
     public void setExecutorService(ExecutorService executorService) {

Modified: camel/trunk/camel-core/src/main/java/org/apache/camel/processor/ThreadsProcessor.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/processor/ThreadsProcessor.java?rev=798057&r1=798056&r2=798057&view=diff
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/processor/ThreadsProcessor.java
(original)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/processor/ThreadsProcessor.java
Mon Jul 27 07:31:57 2009
@@ -39,7 +39,7 @@
  */
 public class ThreadsProcessor extends DelegateProcessor implements Processor {
 
-    protected static final int DEFAULT_THREADPOOL_SIZE = 5;
+    protected static final int DEFAULT_THREADPOOL_SIZE = 10;
     protected ExecutorService executorService;
     protected WaitForTaskToComplete waitForTaskToComplete;
 
@@ -105,7 +105,7 @@
     }
 
     protected ExecutorService createExecutorService() {
-        return ExecutorServiceHelper.newScheduledThreadPool(DEFAULT_THREADPOOL_SIZE, "AsyncProcessor",
true);
+        return ExecutorServiceHelper.newScheduledThreadPool(DEFAULT_THREADPOOL_SIZE, "Threads",
true);
     }
 
     protected void doStop() throws Exception {

Modified: camel/trunk/camel-core/src/main/java/org/apache/camel/processor/WireTapProcessor.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/processor/WireTapProcessor.java?rev=798057&r1=798056&r2=798057&view=diff
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/processor/WireTapProcessor.java
(original)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/processor/WireTapProcessor.java
Mon Jul 27 07:31:57 2009
@@ -37,6 +37,7 @@
  */
 public class WireTapProcessor extends SendProcessor {
 
+    private static final int DEFAULT_THREADPOOL_SIZE = 10;
     private ExecutorService executorService;
 
     // expression or processor used for populating a new exchange to send
@@ -149,7 +150,7 @@
     }
 
     private ExecutorService createExecutorService() {
-        return ExecutorServiceHelper.newScheduledThreadPool(5, this.toString(), true);
+        return ExecutorServiceHelper.newScheduledThreadPool(DEFAULT_THREADPOOL_SIZE, this.toString(),
true);
     }
 
     public void setExecutorService(ExecutorService executorService) {



Mime
View raw message