Author: davsclaus Date: Fri Jul 2 13:34:19 2010 New Revision: 959979 URL: http://svn.apache.org/viewvc?rev=959979&view=rev Log: Polished
Modified: camel/trunk/camel-core/src/main/java/org/apache/camel/processor/RedeliveryErrorHandler.java Modified: camel/trunk/camel-core/src/main/java/org/apache/camel/processor/RedeliveryErrorHandler.java URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/processor/RedeliveryErrorHandler.java?rev=959979&r1=959978&r2=959979&view=diff ============================================================================== --- camel/trunk/camel-core/src/main/java/org/apache/camel/processor/RedeliveryErrorHandler.java (original) +++ camel/trunk/camel-core/src/main/java/org/apache/camel/processor/RedeliveryErrorHandler.java Fri Jul 2 13:34:19 2010 @@ -799,13 +799,10 @@ public abstract class RedeliveryErrorHan @Override protected void doStart() throws Exception { ServiceHelper.startServices(output, outputAsync, deadLetter); - // use pool size from default profile - int poolSize = camelContext.getExecutorServiceStrategy().getDefaultThreadPoolProfile().getPoolSize(); - // use a shared scheduler + // use a shared scheduler if (executorService == null || executorService.isShutdown()) { // camel context will shutdown the executor when it shutdown so no need to shut it down when stopping - executorService = camelContext.getExecutorServiceStrategy().newScheduledThreadPool(this, - "RedeliveryErrorHandler-RedeliveryTask", poolSize); + executorService = camelContext.getExecutorServiceStrategy().newScheduledThreadPool(this, "ErrorHandlerRedeliveryTask"); } }