Author: davsclaus Date: Sat Jul 10 07:13:40 2010 New Revision: 962775 URL: http://svn.apache.org/viewvc?rev=962775&view=rev Log: Polished test
Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/processor/ShutdownCompleteAllTasksTest.java camel/trunk/camel-core/src/test/java/org/apache/camel/processor/ShutdownCompleteCurrentTaskOnlyTest.java Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/processor/ShutdownCompleteAllTasksTest.java URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/ShutdownCompleteAllTasksTest.java?rev=962775&r1=962774&r2=962775&view=diff ============================================================================== --- camel/trunk/camel-core/src/test/java/org/apache/camel/processor/ShutdownCompleteAllTasksTest.java (original) +++ camel/trunk/camel-core/src/test/java/org/apache/camel/processor/ShutdownCompleteAllTasksTest.java Sat Jul 10 07:13:40 2010 @@ -45,6 +45,9 @@ public class ShutdownCompleteAllTasksTes // give it 20 seconds to shutdown context.getShutdownStrategy().setTimeout(20); + // start route which will pickup the 5 files + context.startRoute("route1"); + MockEndpoint bar = getMockEndpoint("mock:bar"); bar.expectedMinimumMessageCount(1); @@ -63,7 +66,7 @@ public class ShutdownCompleteAllTasksTes @Override // START SNIPPET: e1 public void configure() throws Exception { - from(url) + from(url).routeId("route1").noAutoStartup() // let it complete all tasks during shutdown .shutdownRunningTask(ShutdownRunningTask.CompleteAllTasks) .delay(1000).to("seda:foo"); Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/processor/ShutdownCompleteCurrentTaskOnlyTest.java URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/ShutdownCompleteCurrentTaskOnlyTest.java?rev=962775&r1=962774&r2=962775&view=diff ============================================================================== --- camel/trunk/camel-core/src/test/java/org/apache/camel/processor/ShutdownCompleteCurrentTaskOnlyTest.java (original) +++ camel/trunk/camel-core/src/test/java/org/apache/camel/processor/ShutdownCompleteCurrentTaskOnlyTest.java Sat Jul 10 07:13:40 2010 @@ -45,6 +45,9 @@ public class ShutdownCompleteCurrentTask // give it 20 seconds to shutdown context.getShutdownStrategy().setTimeout(20); + // start route which will pickup the 5 files + context.startRoute("route1"); + MockEndpoint bar = getMockEndpoint("mock:bar"); bar.expectedMinimumMessageCount(1); @@ -62,7 +65,7 @@ public class ShutdownCompleteCurrentTask return new RouteBuilder() { @Override public void configure() throws Exception { - from(url).routeId("route1") + from(url).routeId("route1").noAutoStartup() // let it complete only current task so we shutdown faster .shutdownRunningTask(ShutdownRunningTask.CompleteCurrentTaskOnly) .delay(1000).to("seda:foo");