camel-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From davscl...@apache.org
Subject svn commit: r1198199 - /camel/trunk/tests/camel-itest/src/test/java/org/apache/camel/itest/quartz/FtpCronScheduledRoutePolicyTest.java
Date Sun, 06 Nov 2011 07:40:58 GMT
Author: davsclaus
Date: Sun Nov  6 07:40:57 2011
New Revision: 1198199

URL: http://svn.apache.org/viewvc?rev=1198199&view=rev
Log:
CAMEL-4605: Polished so code can backport.

Modified:
    camel/trunk/tests/camel-itest/src/test/java/org/apache/camel/itest/quartz/FtpCronScheduledRoutePolicyTest.java

Modified: camel/trunk/tests/camel-itest/src/test/java/org/apache/camel/itest/quartz/FtpCronScheduledRoutePolicyTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/tests/camel-itest/src/test/java/org/apache/camel/itest/quartz/FtpCronScheduledRoutePolicyTest.java?rev=1198199&r1=1198198&r2=1198199&view=diff
==============================================================================
--- camel/trunk/tests/camel-itest/src/test/java/org/apache/camel/itest/quartz/FtpCronScheduledRoutePolicyTest.java
(original)
+++ camel/trunk/tests/camel-itest/src/test/java/org/apache/camel/itest/quartz/FtpCronScheduledRoutePolicyTest.java
Sun Nov  6 07:40:57 2011
@@ -22,9 +22,7 @@ import java.util.concurrent.TimeUnit;
 import org.apache.camel.Exchange;
 import org.apache.camel.ShutdownRunningTask;
 import org.apache.camel.builder.RouteBuilder;
-import org.apache.camel.builder.ThreadPoolProfileBuilder;
 import org.apache.camel.routepolicy.quartz.CronScheduledRoutePolicy;
-import org.apache.camel.spi.ThreadPoolProfile;
 import org.apache.camel.test.junit4.CamelTestSupport;
 import org.apache.ftpserver.FtpServer;
 import org.apache.ftpserver.FtpServerFactory;
@@ -63,11 +61,6 @@ public class FtpCronScheduledRoutePolicy
                 policy.setRouteStopGracePeriod(250);
                 policy.setTimeUnit(TimeUnit.SECONDS);
 
-                ThreadPoolProfile profile = new ThreadPoolProfileBuilder("foo")
-                    .poolSize(2).maxPoolSize(2).maxPoolSize(-1).build();
-
-                context.getExecutorServiceManager().registerThreadPoolProfile(profile);
-
                 from(ftp)
                     .noAutoStartup().routePolicy(policy).shutdownRunningTask(ShutdownRunningTask.CompleteAllTasks)
                     .log("Processing ${file:name}")



Mime
View raw message