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 2011/11/06 08:40:58 UTC
svn commit: r1198199 -
/camel/trunk/tests/camel-itest/src/test/java/org/apache/camel/itest/quartz/FtpCronScheduledRoutePolicyTest.java
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}")