camel-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From davscl...@apache.org
Subject [1/3] camel git commit: CAMEL-11446: Use awaitility in camel-core for testing where we otherwise use thred sleep which can be speeded up.
Date Sat, 08 Jul 2017 10:47:04 GMT
Repository: camel
Updated Branches:
  refs/heads/master dcb001f0d -> ffc08f480


CAMEL-11446: Use awaitility in camel-core for testing where we otherwise use thred sleep which can be speeded up.


Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/cc1edc91
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/cc1edc91
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/cc1edc91

Branch: refs/heads/master
Commit: cc1edc915b85cda9a37b677d9321a7dc8fd25f31
Parents: dcb001f
Author: Claus Ibsen <davsclaus@apache.org>
Authored: Sat Jul 8 11:07:06 2017 +0200
Committer: Claus Ibsen <davsclaus@apache.org>
Committed: Sat Jul 8 11:07:06 2017 +0200

----------------------------------------------------------------------
 .../AntPathMatcherGenericFileFilterTest.java    | 30 ++++++----
 .../file/DirectoryCreateIssueTest.java          |  2 +-
 .../FileAbsoluteAndRelativeConsumerTest.java    |  4 +-
 .../file/FileAbsolutePathIssueTest.java         |  2 +-
 .../file/FileBeginFailureOneTimeTest.java       |  2 +-
 .../file/FileBrowsableEndpointTest.java         |  8 +--
 .../FileConcurrentWriteAppendSameFileTest.java  |  4 +-
 ...FileConsumeAlterFileNameHeaderIssueTest.java |  8 +--
 .../component/file/FileConsumeAsyncTest.java    | 63 --------------------
 .../file/FileConsumeBackoffMultiplierTest.java  |  3 +-
 .../component/file/FileConsumeCharsetTest.java  |  2 +-
 .../file/FileConsumeDoneFileIssueTest.java      |  8 +--
 .../file/FileConsumeFilesAndDeleteTest.java     | 10 ++--
 .../file/FileConsumeMaxMessagesPerPollTest.java |  2 +-
 .../file/FileConsumeMoveRelativeNameTest.java   |  2 +-
 .../FileConsumeMultipleDirectoriesTest.java     |  9 +--
 .../file/FileConsumeNoopIdempotentAutoTest.java |  2 +-
 .../FileConsumeNoopIdempotentDisabledTest.java  |  2 +-
 .../FileConsumeNoopIdempotentEnabledTest.java   |  7 ++-
 ...leConsumeNotEagerMaxMessagesPerPollTest.java | 17 ++++--
 .../FilerConsumerDoneFileNameDeleteTest.java    |  2 +-
 .../file/stress/FileAsyncStressFileDropper.java |  2 +
 .../file/stress/FileAsyncStressManually.java    |  2 +
 .../FileAsyncStressReadLockLockFileTest.java    |  2 +
 .../stress/FileAsyncStressReadLockNoneTest.java |  2 +
 .../FileAsyncStressReadLockRenameTest.java      |  2 +
 .../file/stress/FileAsyncStressTest.java        |  2 +
 .../stress/FileConsumerPollManyFilesTest.java   |  2 +
 .../FileProducerAppendManyMessagesFastTest.java |  2 +
 .../FileProducerAppendManyMessagesTest.java     |  2 +
 30 files changed, 90 insertions(+), 117 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/camel/blob/cc1edc91/camel-core/src/test/java/org/apache/camel/component/file/AntPathMatcherGenericFileFilterTest.java
----------------------------------------------------------------------
diff --git a/camel-core/src/test/java/org/apache/camel/component/file/AntPathMatcherGenericFileFilterTest.java b/camel-core/src/test/java/org/apache/camel/component/file/AntPathMatcherGenericFileFilterTest.java
index 1e4c36a..026ecd3 100644
--- a/camel-core/src/test/java/org/apache/camel/component/file/AntPathMatcherGenericFileFilterTest.java
+++ b/camel-core/src/test/java/org/apache/camel/component/file/AntPathMatcherGenericFileFilterTest.java
@@ -158,17 +158,25 @@ public class AntPathMatcherGenericFileFilterTest extends ContextTestSupport {
     protected RouteBuilder createRouteBuilder() throws Exception {
         return new RouteBuilder() {
             public void configure() throws Exception {
-                from("file://target/files/ant-path-1?recursive=true&antInclude=**/*.txt&antFilterCaseSensitive=true").convertBodyTo(String.class).to("mock:result1");
-                from("file://target/files/ant-path-5?recursive=true&antInclude=**/*.txt&antFilterCaseSensitive=false").convertBodyTo(String.class).to("mock:result5");
-
-                from("file://target/files/ant-path-2?recursive=true&antExclude=**/*.bak").convertBodyTo(String.class).to("mock:result2");
-                from("file://target/files/ant-path-6?recursive=true&antExclude=**/*.bak&antFilterCaseSensitive=false").convertBodyTo(String.class).to("mock:result6");
-
-                from("file://target/files/ant-path-3?recursive=true&antInclude=**/*.pdf,**/*.txt&antExclude=**/a*,**/b*").convertBodyTo(String.class).to("mock:result3");
-                from("file://target/files/ant-path-7?recursive=true&antInclude=**/*.Pdf,**/*.txt&antExclude=**/a*,**/b*&antFilterCaseSensitive=false").convertBodyTo(String.class).to("mock:result7");
-
-                from("file://target/files/ant-path-4?recursive=true&antInclude=**/*.txt&antExclude=**/a*&filter=#filter").convertBodyTo(String.class).to("mock:result4");
-                from("file://target/files/ant-path-8?recursive=true&antInclude=**/*.txt&antExclude=**/a*&filter=#caseInsensitiveFilter").convertBodyTo(String.class).to("mock:result8");
+                from("file://target/files/ant-path-1?initialDelay=0&delay=10&recursive=true&antInclude=**/*.txt&antFilterCaseSensitive=true")
+                    .convertBodyTo(String.class).to("mock:result1");
+                from("file://target/files/ant-path-5?initialDelay=0&delay=10&recursive=true&antInclude=**/*.txt&antFilterCaseSensitive=false")
+                    .convertBodyTo(String.class).to("mock:result5");
+
+                from("file://target/files/ant-path-2?initialDelay=0&delay=10&recursive=true&antExclude=**/*.bak")
+                    .convertBodyTo(String.class).to("mock:result2");
+                from("file://target/files/ant-path-6?initialDelay=0&delay=10&recursive=true&antExclude=**/*.bak&antFilterCaseSensitive=false")
+                    .convertBodyTo(String.class).to("mock:result6");
+
+                from("file://target/files/ant-path-3?initialDelay=0&delay=10&recursive=true&antInclude=**/*.pdf,**/*.txt&antExclude=**/a*,**/b*")
+                    .convertBodyTo(String.class).to("mock:result3");
+                from("file://target/files/ant-path-7?initialDelay=0&delay=10&recursive=true&antInclude=**/*.Pdf,**/*.txt&antExclude=**/a*,**/b*&antFilterCaseSensitive=false")
+                    .convertBodyTo(String.class).to("mock:result7");
+
+                from("file://target/files/ant-path-4?initialDelay=0&delay=10&recursive=true&antInclude=**/*.txt&antExclude=**/a*&filter=#filter")
+                    .convertBodyTo(String.class).to("mock:result4");
+                from("file://target/files/ant-path-8?initialDelay=0&delay=10&recursive=true&antInclude=**/*.txt&antExclude=**/a*&filter=#caseInsensitiveFilter")
+                    .convertBodyTo(String.class).to("mock:result8");
             }
         };
     }

http://git-wip-us.apache.org/repos/asf/camel/blob/cc1edc91/camel-core/src/test/java/org/apache/camel/component/file/DirectoryCreateIssueTest.java
----------------------------------------------------------------------
diff --git a/camel-core/src/test/java/org/apache/camel/component/file/DirectoryCreateIssueTest.java b/camel-core/src/test/java/org/apache/camel/component/file/DirectoryCreateIssueTest.java
index ed3f670..acf4966 100644
--- a/camel-core/src/test/java/org/apache/camel/component/file/DirectoryCreateIssueTest.java
+++ b/camel-core/src/test/java/org/apache/camel/component/file/DirectoryCreateIssueTest.java
@@ -71,7 +71,7 @@ public class DirectoryCreateIssueTest extends ContextTestSupport {
         assertMockEndpointsSatisfied();
 
         // wait a little while for the files to settle down
-        Thread.sleep(200);
+        Thread.sleep(50);
 
         for (int i = 0; i < numFiles; i++) {
             assertTrue((new File(path + "/file" + i + ".txt")).isFile());

http://git-wip-us.apache.org/repos/asf/camel/blob/cc1edc91/camel-core/src/test/java/org/apache/camel/component/file/FileAbsoluteAndRelativeConsumerTest.java
----------------------------------------------------------------------
diff --git a/camel-core/src/test/java/org/apache/camel/component/file/FileAbsoluteAndRelativeConsumerTest.java b/camel-core/src/test/java/org/apache/camel/component/file/FileAbsoluteAndRelativeConsumerTest.java
index 0c0b808..2033ff3 100644
--- a/camel-core/src/test/java/org/apache/camel/component/file/FileAbsoluteAndRelativeConsumerTest.java
+++ b/camel-core/src/test/java/org/apache/camel/component/file/FileAbsoluteAndRelativeConsumerTest.java
@@ -68,9 +68,9 @@ public class FileAbsoluteAndRelativeConsumerTest extends ContextTestSupport {
         return new RouteBuilder() {
             @Override
             public void configure() throws Exception {
-                from("file://target/filerelative?recursive=true").convertBodyTo(String.class).to("mock:relative");
+                from("file://target/filerelative?initialDelay=0&delay=10&recursive=true").convertBodyTo(String.class).to("mock:relative");
 
-                from("file://" + base + "?recursive=true").convertBodyTo(String.class).to("mock:absolute");
+                from("file://" + base + "?initialDelay=0&delay=10&recursive=true").convertBodyTo(String.class).to("mock:absolute");
             }
         };
     }

http://git-wip-us.apache.org/repos/asf/camel/blob/cc1edc91/camel-core/src/test/java/org/apache/camel/component/file/FileAbsolutePathIssueTest.java
----------------------------------------------------------------------
diff --git a/camel-core/src/test/java/org/apache/camel/component/file/FileAbsolutePathIssueTest.java b/camel-core/src/test/java/org/apache/camel/component/file/FileAbsolutePathIssueTest.java
index d89b977..ce80210 100644
--- a/camel-core/src/test/java/org/apache/camel/component/file/FileAbsolutePathIssueTest.java
+++ b/camel-core/src/test/java/org/apache/camel/component/file/FileAbsolutePathIssueTest.java
@@ -39,7 +39,7 @@ public class FileAbsolutePathIssueTest extends ContextTestSupport {
 
         start = new File("target/issue").getAbsolutePath();
         done = new File("target/done").getAbsolutePath();
-        uri = "file:" + start + "?move=" + done + "/${file:name}";
+        uri = "file:" + start + "?initialDelay=0&delay=10&move=" + done + "/${file:name}";
 
         super.setUp();
     }

http://git-wip-us.apache.org/repos/asf/camel/blob/cc1edc91/camel-core/src/test/java/org/apache/camel/component/file/FileBeginFailureOneTimeTest.java
----------------------------------------------------------------------
diff --git a/camel-core/src/test/java/org/apache/camel/component/file/FileBeginFailureOneTimeTest.java b/camel-core/src/test/java/org/apache/camel/component/file/FileBeginFailureOneTimeTest.java
index 1391f33..78cd83c 100644
--- a/camel-core/src/test/java/org/apache/camel/component/file/FileBeginFailureOneTimeTest.java
+++ b/camel-core/src/test/java/org/apache/camel/component/file/FileBeginFailureOneTimeTest.java
@@ -60,7 +60,7 @@ public class FileBeginFailureOneTimeTest extends ContextTestSupport {
         return new RouteBuilder() {
             @Override
             public void configure() throws Exception {
-                from("file://target/begin?processStrategy=#myStrategy")
+                from("file://target/begin?initialDelay=0&delay=10&processStrategy=#myStrategy")
                     .convertBodyTo(String.class)
                     .to("mock:result");
             }

http://git-wip-us.apache.org/repos/asf/camel/blob/cc1edc91/camel-core/src/test/java/org/apache/camel/component/file/FileBrowsableEndpointTest.java
----------------------------------------------------------------------
diff --git a/camel-core/src/test/java/org/apache/camel/component/file/FileBrowsableEndpointTest.java b/camel-core/src/test/java/org/apache/camel/component/file/FileBrowsableEndpointTest.java
index 16c97f4..a850f2f 100644
--- a/camel-core/src/test/java/org/apache/camel/component/file/FileBrowsableEndpointTest.java
+++ b/camel-core/src/test/java/org/apache/camel/component/file/FileBrowsableEndpointTest.java
@@ -41,7 +41,7 @@ public class FileBrowsableEndpointTest extends ContextTestSupport {
     }
 
     public void testBrowsableNoFiles() throws Exception {
-        BrowsableEndpoint browse = context.getEndpoint("file:target/browse", BrowsableEndpoint.class);
+        BrowsableEndpoint browse = context.getEndpoint("file:target/browse?initialDelay=0&delay=10", BrowsableEndpoint.class);
         assertNotNull(browse);
 
         List<Exchange> list = browse.getExchanges();
@@ -52,7 +52,7 @@ public class FileBrowsableEndpointTest extends ContextTestSupport {
     public void testBrowsableOneFile() throws Exception {
         template.sendBodyAndHeader("file:target/browse", "A", Exchange.FILE_NAME, "a.txt");
 
-        FileEndpoint endpoint = context.getEndpoint("file:target/browse", FileEndpoint.class);
+        FileEndpoint endpoint = context.getEndpoint("file:target/browse?initialDelay=0&delay=10", FileEndpoint.class);
         assertNotNull(endpoint);
 
         MemoryIdempotentRepository repo = (MemoryIdempotentRepository) endpoint.getInProgressRepository();
@@ -76,7 +76,7 @@ public class FileBrowsableEndpointTest extends ContextTestSupport {
         template.sendBodyAndHeader("file:target/browse", "A", Exchange.FILE_NAME, "a.txt");
         template.sendBodyAndHeader("file:target/browse", "B", Exchange.FILE_NAME, "b.txt");
 
-        FileEndpoint endpoint = context.getEndpoint("file:target/browse?sortBy=file:name", FileEndpoint.class);
+        FileEndpoint endpoint = context.getEndpoint("file:target/browse?initialDelay=0&delay=10&sortBy=file:name", FileEndpoint.class);
         assertNotNull(endpoint);
 
         MemoryIdempotentRepository repo = (MemoryIdempotentRepository) endpoint.getInProgressRepository();
@@ -104,7 +104,7 @@ public class FileBrowsableEndpointTest extends ContextTestSupport {
         template.sendBodyAndHeader("file:target/browse", "B", Exchange.FILE_NAME, "foo/b.txt");
         template.sendBodyAndHeader("file:target/browse", "C", Exchange.FILE_NAME, "bar/c.txt");
 
-        FileEndpoint endpoint = context.getEndpoint("file:target/browse?recursive=true&sortBy=file:name", FileEndpoint.class);
+        FileEndpoint endpoint = context.getEndpoint("file:target/browse?initialDelay=0&delay=10&recursive=true&sortBy=file:name", FileEndpoint.class);
         assertNotNull(endpoint);
 
         MemoryIdempotentRepository repo = (MemoryIdempotentRepository) endpoint.getInProgressRepository();

http://git-wip-us.apache.org/repos/asf/camel/blob/cc1edc91/camel-core/src/test/java/org/apache/camel/component/file/FileConcurrentWriteAppendSameFileTest.java
----------------------------------------------------------------------
diff --git a/camel-core/src/test/java/org/apache/camel/component/file/FileConcurrentWriteAppendSameFileTest.java b/camel-core/src/test/java/org/apache/camel/component/file/FileConcurrentWriteAppendSameFileTest.java
index 40c08fd..d663e31 100644
--- a/camel-core/src/test/java/org/apache/camel/component/file/FileConcurrentWriteAppendSameFileTest.java
+++ b/camel-core/src/test/java/org/apache/camel/component/file/FileConcurrentWriteAppendSameFileTest.java
@@ -52,7 +52,7 @@ public class FileConcurrentWriteAppendSameFileTest extends ContextTestSupport {
         mock.setResultWaitTime(30000);
 
         // we need to wait a bit for our slow CI server to make sure the entire file is written on disc
-        Thread.sleep(1000);
+        Thread.sleep(500);
         context.startRoute("foo");
 
         assertMockEndpointsSatisfied();
@@ -76,7 +76,7 @@ public class FileConcurrentWriteAppendSameFileTest extends ContextTestSupport {
         return new RouteBuilder() {
             @Override
             public void configure() throws Exception {
-                from("file:target/concurrent").routeId("foo").noAutoStartup()
+                from("file:target/concurrent?initialDelay=0&delay=10").routeId("foo").noAutoStartup()
                     .split(body().tokenize(LS)).parallelProcessing().streaming()
                         .setBody(body().append(":Status=OK").append(LS))
                         .to("file:target/concurrent/outbox?fileExist=Append&fileName=result.txt")

http://git-wip-us.apache.org/repos/asf/camel/blob/cc1edc91/camel-core/src/test/java/org/apache/camel/component/file/FileConsumeAlterFileNameHeaderIssueTest.java
----------------------------------------------------------------------
diff --git a/camel-core/src/test/java/org/apache/camel/component/file/FileConsumeAlterFileNameHeaderIssueTest.java b/camel-core/src/test/java/org/apache/camel/component/file/FileConsumeAlterFileNameHeaderIssueTest.java
index c9c6d85..f3c1ef6 100644
--- a/camel-core/src/test/java/org/apache/camel/component/file/FileConsumeAlterFileNameHeaderIssueTest.java
+++ b/camel-core/src/test/java/org/apache/camel/component/file/FileConsumeAlterFileNameHeaderIssueTest.java
@@ -43,7 +43,7 @@ public class FileConsumeAlterFileNameHeaderIssueTest extends ContextTestSupport
         context.addRoutes(new RouteBuilder() {
             @Override
             public void configure() throws Exception {
-                from("file://target/files?delete=true")
+                from("file://target/files?initialDelay=0&delay=10&delete=true")
                     // remove all headers
                     .removeHeaders("*")
                     .to("mock:result");
@@ -70,7 +70,7 @@ public class FileConsumeAlterFileNameHeaderIssueTest extends ContextTestSupport
         context.addRoutes(new RouteBuilder() {
             @Override
             public void configure() throws Exception {
-                from("file://target/files?delete=true")
+                from("file://target/files?initialDelay=0&delay=10&delete=true")
                     // change file header
                     .setHeader(Exchange.FILE_NAME, constant("bye.txt"))
                     .to("mock:result");
@@ -96,7 +96,7 @@ public class FileConsumeAlterFileNameHeaderIssueTest extends ContextTestSupport
         context.addRoutes(new RouteBuilder() {
             @Override
             public void configure() throws Exception {
-                from("file://target/files")
+                from("file://target/files?initialDelay=0&delay=10")
                     // remove all headers
                     .removeHeaders("*")
                     .to("mock:result");
@@ -123,7 +123,7 @@ public class FileConsumeAlterFileNameHeaderIssueTest extends ContextTestSupport
         context.addRoutes(new RouteBuilder() {
             @Override
             public void configure() throws Exception {
-                from("file://target/files")
+                from("file://target/files?initialDelay=0&delay=10")
                     // change file header
                     .setHeader(Exchange.FILE_NAME, constant("bye.txt"))
                     .to("mock:result");

http://git-wip-us.apache.org/repos/asf/camel/blob/cc1edc91/camel-core/src/test/java/org/apache/camel/component/file/FileConsumeAsyncTest.java
----------------------------------------------------------------------
diff --git a/camel-core/src/test/java/org/apache/camel/component/file/FileConsumeAsyncTest.java b/camel-core/src/test/java/org/apache/camel/component/file/FileConsumeAsyncTest.java
deleted file mode 100644
index ba0a6c0..0000000
--- a/camel-core/src/test/java/org/apache/camel/component/file/FileConsumeAsyncTest.java
+++ /dev/null
@@ -1,63 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License.  You may obtain a copy of the License at
- *
- *      http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.camel.component.file;
-
-import java.io.File;
-
-import org.apache.camel.ContextTestSupport;
-import org.apache.camel.Exchange;
-import org.apache.camel.builder.RouteBuilder;
-
-/**
- * Unit test for consuming the same filename only.
- */
-public class FileConsumeAsyncTest extends ContextTestSupport {
-
-    @Override
-    protected void setUp() throws Exception {
-        deleteDirectory("target/files");
-        super.setUp();
-        template.sendBodyAndHeader("file://target/files", "Hello World", Exchange.FILE_NAME, "report.txt");
-    }
-
-    public void testConsumeAsync() throws Exception {
-        getMockEndpoint("mock:before").expectedBodiesReceived("Hello World");
-        getMockEndpoint("mock:result").expectedBodiesReceived("Hello World");
-
-        // file should still exist as its the async done that will complete it
-        assertTrue("File should not have been deleted", new File("target/files/report.txt").exists());
-
-        oneExchangeDone.matchesMockWaitTime();
-        assertMockEndpointsSatisfied();
-
-        assertFalse("File should have been deleted", new File("target/files/report.txt").exists());
-    }
-
-    @Override
-    protected RouteBuilder createRouteBuilder() throws Exception {
-        return new RouteBuilder() {
-            public void configure() throws Exception {
-                from("file://target/files/?delete=true&delay=10000")
-                    .convertBodyTo(String.class)
-                    .threads()
-                        .to("mock:before")
-                        .delay(1000)
-                        .to("mock:result");
-            }
-        };
-    }
-}
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/camel/blob/cc1edc91/camel-core/src/test/java/org/apache/camel/component/file/FileConsumeBackoffMultiplierTest.java
----------------------------------------------------------------------
diff --git a/camel-core/src/test/java/org/apache/camel/component/file/FileConsumeBackoffMultiplierTest.java b/camel-core/src/test/java/org/apache/camel/component/file/FileConsumeBackoffMultiplierTest.java
index 45ace58..4652f2a 100644
--- a/camel-core/src/test/java/org/apache/camel/component/file/FileConsumeBackoffMultiplierTest.java
+++ b/camel-core/src/test/java/org/apache/camel/component/file/FileConsumeBackoffMultiplierTest.java
@@ -46,7 +46,8 @@ public class FileConsumeBackoffMultiplierTest extends ContextTestSupport {
     protected RouteBuilder createRouteBuilder() throws Exception {
         return new RouteBuilder() {
             public void configure() throws Exception {
-                from("file://target/files/?delete=true&backoffMultiplier=4&backoffIdleThreshold=3").convertBodyTo(String.class).to("mock:result");
+                from("file://target/files/?initialDelay=0&delay=10&delete=true&backoffMultiplier=4&backoffIdleThreshold=3")
+                    .convertBodyTo(String.class).to("mock:result");
             }
         };
     }

http://git-wip-us.apache.org/repos/asf/camel/blob/cc1edc91/camel-core/src/test/java/org/apache/camel/component/file/FileConsumeCharsetTest.java
----------------------------------------------------------------------
diff --git a/camel-core/src/test/java/org/apache/camel/component/file/FileConsumeCharsetTest.java b/camel-core/src/test/java/org/apache/camel/component/file/FileConsumeCharsetTest.java
index 8937506..6b2230b 100644
--- a/camel-core/src/test/java/org/apache/camel/component/file/FileConsumeCharsetTest.java
+++ b/camel-core/src/test/java/org/apache/camel/component/file/FileConsumeCharsetTest.java
@@ -51,7 +51,7 @@ public class FileConsumeCharsetTest extends ContextTestSupport {
     protected RouteBuilder createRouteBuilder() throws Exception {
         return new RouteBuilder() {
             public void configure() throws Exception {
-                from("file://target/files/?fileName=report.txt&delete=true&charset=UTF-8")
+                from("file://target/files/?initialDelay=0&delay=10&fileName=report.txt&delete=true&charset=UTF-8")
                     .convertBodyTo(String.class)
                     .to("mock:result");
             }

http://git-wip-us.apache.org/repos/asf/camel/blob/cc1edc91/camel-core/src/test/java/org/apache/camel/component/file/FileConsumeDoneFileIssueTest.java
----------------------------------------------------------------------
diff --git a/camel-core/src/test/java/org/apache/camel/component/file/FileConsumeDoneFileIssueTest.java b/camel-core/src/test/java/org/apache/camel/component/file/FileConsumeDoneFileIssueTest.java
index 4f05221..6b09323 100644
--- a/camel-core/src/test/java/org/apache/camel/component/file/FileConsumeDoneFileIssueTest.java
+++ b/camel-core/src/test/java/org/apache/camel/component/file/FileConsumeDoneFileIssueTest.java
@@ -54,7 +54,7 @@ public class FileConsumeDoneFileIssueTest extends ContextTestSupport {
         assertMockEndpointsSatisfied();
         assertTrue(notify.matchesMockWaitTime());
 
-        Thread.sleep(250);
+        Thread.sleep(50);
 
         // the done file should be deleted
         assertFalse("Done file should be deleted", new File("target/done/foo.done").exists());
@@ -81,7 +81,7 @@ public class FileConsumeDoneFileIssueTest extends ContextTestSupport {
         assertMockEndpointsSatisfied();
         assertTrue(notify.matchesMockWaitTime());
 
-        Thread.sleep(250);
+        Thread.sleep(50);
 
         // the done file should be deleted
         assertFalse("Done file should be deleted", new File("target/done2/a.txt.done").exists());
@@ -95,11 +95,11 @@ public class FileConsumeDoneFileIssueTest extends ContextTestSupport {
         return new RouteBuilder() {
             @Override
             public void configure() throws Exception {
-                from("file:target/done?doneFileName=foo.done").routeId("foo").noAutoStartup()
+                from("file:target/done?doneFileName=foo.done&initialDelay=0&delay=10").routeId("foo").noAutoStartup()
                     .convertBodyTo(String.class)
                     .to("mock:result");
                 
-                from("file:target/done2?doneFileName=${file:name}.done")
+                from("file:target/done2?doneFileName=${file:name}.done&initialDelay=0&delay=10")
                     .routeId("bar").noAutoStartup()
                     .convertBodyTo(String.class)
                     .to("mock:result");

http://git-wip-us.apache.org/repos/asf/camel/blob/cc1edc91/camel-core/src/test/java/org/apache/camel/component/file/FileConsumeFilesAndDeleteTest.java
----------------------------------------------------------------------
diff --git a/camel-core/src/test/java/org/apache/camel/component/file/FileConsumeFilesAndDeleteTest.java b/camel-core/src/test/java/org/apache/camel/component/file/FileConsumeFilesAndDeleteTest.java
index f0e713b..c23425b 100644
--- a/camel-core/src/test/java/org/apache/camel/component/file/FileConsumeFilesAndDeleteTest.java
+++ b/camel-core/src/test/java/org/apache/camel/component/file/FileConsumeFilesAndDeleteTest.java
@@ -32,15 +32,16 @@ public class FileConsumeFilesAndDeleteTest extends ContextTestSupport {
     protected void setUp() throws Exception {
         deleteDirectory("target/files");
         super.setUp();
-        template.sendBodyAndHeader("file://target/files", "Hello World", Exchange.FILE_NAME, "report.txt");
-        template.sendBodyAndHeader("file://target/files", "Bye World", Exchange.FILE_NAME, "report2.txt");
-        template.sendBodyAndHeader("file://target/files/2008", "2008 Report", Exchange.FILE_NAME, "report2008.txt");
     }
 
     public void testConsumeAndDelete() throws Exception {
         MockEndpoint mock = getMockEndpoint("mock:result");
         mock.expectedBodiesReceived("Hello World");
 
+        template.sendBodyAndHeader("file://target/files", "Bye World", Exchange.FILE_NAME, "report2.txt");
+        template.sendBodyAndHeader("file://target/files", "Hello World", Exchange.FILE_NAME, "report.txt");
+        template.sendBodyAndHeader("file://target/files/2008", "2008 Report", Exchange.FILE_NAME, "report2008.txt");
+
         assertMockEndpointsSatisfied();
 
         oneExchangeDone.matchesMockWaitTime();
@@ -53,7 +54,8 @@ public class FileConsumeFilesAndDeleteTest extends ContextTestSupport {
     protected RouteBuilder createRouteBuilder() throws Exception {
         return new RouteBuilder() {
             public void configure() throws Exception {
-                from("file://target/files/?fileName=report.txt&delete=true").convertBodyTo(String.class).to("mock:result");
+                from("file://target/files/?initialDelay=0&delay=10&fileName=report.txt&delete=true")
+                    .convertBodyTo(String.class).to("mock:result");
             }
         };
     }

http://git-wip-us.apache.org/repos/asf/camel/blob/cc1edc91/camel-core/src/test/java/org/apache/camel/component/file/FileConsumeMaxMessagesPerPollTest.java
----------------------------------------------------------------------
diff --git a/camel-core/src/test/java/org/apache/camel/component/file/FileConsumeMaxMessagesPerPollTest.java b/camel-core/src/test/java/org/apache/camel/component/file/FileConsumeMaxMessagesPerPollTest.java
index 84457cc..be920ba 100644
--- a/camel-core/src/test/java/org/apache/camel/component/file/FileConsumeMaxMessagesPerPollTest.java
+++ b/camel-core/src/test/java/org/apache/camel/component/file/FileConsumeMaxMessagesPerPollTest.java
@@ -26,7 +26,7 @@ import org.apache.camel.component.mock.MockEndpoint;
  */
 public class FileConsumeMaxMessagesPerPollTest extends ContextTestSupport {
 
-    private String fileUrl = "file://target/poll/?maxMessagesPerPoll=2";
+    private String fileUrl = "file://target/poll/?initialDelay=0&delay=10&maxMessagesPerPoll=2";
 
     @Override
     protected void setUp() throws Exception {

http://git-wip-us.apache.org/repos/asf/camel/blob/cc1edc91/camel-core/src/test/java/org/apache/camel/component/file/FileConsumeMoveRelativeNameTest.java
----------------------------------------------------------------------
diff --git a/camel-core/src/test/java/org/apache/camel/component/file/FileConsumeMoveRelativeNameTest.java b/camel-core/src/test/java/org/apache/camel/component/file/FileConsumeMoveRelativeNameTest.java
index 845da58..f1b132d 100644
--- a/camel-core/src/test/java/org/apache/camel/component/file/FileConsumeMoveRelativeNameTest.java
+++ b/camel-core/src/test/java/org/apache/camel/component/file/FileConsumeMoveRelativeNameTest.java
@@ -26,7 +26,7 @@ import org.apache.camel.component.mock.MockEndpoint;
  */
 public class FileConsumeMoveRelativeNameTest extends ContextTestSupport {
 
-    private String fileUrl = "file://target/multidir/?recursive=true&move=.done/${file:name}.old";
+    private String fileUrl = "file://target/multidir/?initialDelay=0&delay=10&recursive=true&move=.done/${file:name}.old";
 
     @Override
     protected void setUp() throws Exception {

http://git-wip-us.apache.org/repos/asf/camel/blob/cc1edc91/camel-core/src/test/java/org/apache/camel/component/file/FileConsumeMultipleDirectoriesTest.java
----------------------------------------------------------------------
diff --git a/camel-core/src/test/java/org/apache/camel/component/file/FileConsumeMultipleDirectoriesTest.java b/camel-core/src/test/java/org/apache/camel/component/file/FileConsumeMultipleDirectoriesTest.java
index 7e8d23b..1154983 100644
--- a/camel-core/src/test/java/org/apache/camel/component/file/FileConsumeMultipleDirectoriesTest.java
+++ b/camel-core/src/test/java/org/apache/camel/component/file/FileConsumeMultipleDirectoriesTest.java
@@ -28,15 +28,12 @@ import org.apache.camel.component.mock.MockEndpoint;
  */
 public class FileConsumeMultipleDirectoriesTest extends ContextTestSupport {
 
-    private String fileUrl = "file://target/multidir/?recursive=true&delete=true&initialDelay=2000&delay=5000&sortBy=file:path";
+    private String fileUrl = "file://target/multidir/?initialDelay=0&delay=10&recursive=true&delete=true&sortBy=file:path";
 
     @Override
     protected void setUp() throws Exception {
         deleteDirectory("target/multidir");
         super.setUp();
-        template.sendBodyAndHeader(fileUrl, "Bye World", Exchange.FILE_NAME, "bye.txt");
-        template.sendBodyAndHeader(fileUrl, "Hello World", Exchange.FILE_NAME, "sub/hello.txt");
-        template.sendBodyAndHeader(fileUrl, "Godday World", Exchange.FILE_NAME, "sub/sub2/godday.txt");
     }
 
     @SuppressWarnings("unchecked")
@@ -44,6 +41,10 @@ public class FileConsumeMultipleDirectoriesTest extends ContextTestSupport {
         MockEndpoint mock = getMockEndpoint("mock:result");
         mock.expectedBodiesReceived("Bye World", "Hello World", "Godday World");
 
+        template.sendBodyAndHeader(fileUrl, "Bye World", Exchange.FILE_NAME, "bye.txt");
+        template.sendBodyAndHeader(fileUrl, "Hello World", Exchange.FILE_NAME, "sub/hello.txt");
+        template.sendBodyAndHeader(fileUrl, "Godday World", Exchange.FILE_NAME, "sub/sub2/godday.txt");
+
         assertMockEndpointsSatisfied();
 
         Exchange exchange =  mock.getExchanges().get(0);

http://git-wip-us.apache.org/repos/asf/camel/blob/cc1edc91/camel-core/src/test/java/org/apache/camel/component/file/FileConsumeNoopIdempotentAutoTest.java
----------------------------------------------------------------------
diff --git a/camel-core/src/test/java/org/apache/camel/component/file/FileConsumeNoopIdempotentAutoTest.java b/camel-core/src/test/java/org/apache/camel/component/file/FileConsumeNoopIdempotentAutoTest.java
index 6e1655e..dc5d8c1 100644
--- a/camel-core/src/test/java/org/apache/camel/component/file/FileConsumeNoopIdempotentAutoTest.java
+++ b/camel-core/src/test/java/org/apache/camel/component/file/FileConsumeNoopIdempotentAutoTest.java
@@ -30,7 +30,7 @@ public class FileConsumeNoopIdempotentAutoTest extends FileConsumeNoopIdempotent
         return new RouteBuilder() {
             @Override
             public void configure() throws Exception {
-                from("file://target/noop?noop=true").convertBodyTo(String.class).to("mock:result");
+                from("file://target/noop?initialDelay=0&delay=10&noop=true").convertBodyTo(String.class).to("mock:result");
             }
         };
     }

http://git-wip-us.apache.org/repos/asf/camel/blob/cc1edc91/camel-core/src/test/java/org/apache/camel/component/file/FileConsumeNoopIdempotentDisabledTest.java
----------------------------------------------------------------------
diff --git a/camel-core/src/test/java/org/apache/camel/component/file/FileConsumeNoopIdempotentDisabledTest.java b/camel-core/src/test/java/org/apache/camel/component/file/FileConsumeNoopIdempotentDisabledTest.java
index 676a36d..1337e04 100644
--- a/camel-core/src/test/java/org/apache/camel/component/file/FileConsumeNoopIdempotentDisabledTest.java
+++ b/camel-core/src/test/java/org/apache/camel/component/file/FileConsumeNoopIdempotentDisabledTest.java
@@ -46,7 +46,7 @@ public class FileConsumeNoopIdempotentDisabledTest extends ContextTestSupport {
         return new RouteBuilder() {
             @Override
             public void configure() throws Exception {
-                from("file://target/noop?noop=true&idempotent=false").convertBodyTo(String.class).to("mock:result");
+                from("file://target/noop?initialDelay=0&delay=10&noop=true&idempotent=false").convertBodyTo(String.class).to("mock:result");
             }
         };
     }

http://git-wip-us.apache.org/repos/asf/camel/blob/cc1edc91/camel-core/src/test/java/org/apache/camel/component/file/FileConsumeNoopIdempotentEnabledTest.java
----------------------------------------------------------------------
diff --git a/camel-core/src/test/java/org/apache/camel/component/file/FileConsumeNoopIdempotentEnabledTest.java b/camel-core/src/test/java/org/apache/camel/component/file/FileConsumeNoopIdempotentEnabledTest.java
index 3fde598..dbac80f 100644
--- a/camel-core/src/test/java/org/apache/camel/component/file/FileConsumeNoopIdempotentEnabledTest.java
+++ b/camel-core/src/test/java/org/apache/camel/component/file/FileConsumeNoopIdempotentEnabledTest.java
@@ -30,7 +30,6 @@ public class FileConsumeNoopIdempotentEnabledTest extends ContextTestSupport {
     protected void setUp() throws Exception {
         deleteDirectory("target/noop");
         super.setUp();
-        template.sendBodyAndHeader("file://target/noop", "Hello World", Exchange.FILE_NAME, "hello.txt");
     }
 
     public void testNoop() throws Exception {
@@ -38,8 +37,10 @@ public class FileConsumeNoopIdempotentEnabledTest extends ContextTestSupport {
         // should only be able to read the file once as idempotent is true
         mock.expectedMessageCount(1);
 
+        template.sendBodyAndHeader("file://target/noop", "Hello World", Exchange.FILE_NAME, "hello.txt");
+
         // give some time to let consumer try to read the file multiple times
-        Thread.sleep(250);
+        Thread.sleep(50);
 
         assertMockEndpointsSatisfied();
     }
@@ -49,7 +50,7 @@ public class FileConsumeNoopIdempotentEnabledTest extends ContextTestSupport {
         return new RouteBuilder() {
             @Override
             public void configure() throws Exception {
-                from("file://target/noop?noop=true&idempotent=true&delay=10").convertBodyTo(String.class).to("mock:result");
+                from("file://target/noop?noop=true&idempotent=true&initialDelay=0&delay=10").convertBodyTo(String.class).to("mock:result");
             }
         };
     }

http://git-wip-us.apache.org/repos/asf/camel/blob/cc1edc91/camel-core/src/test/java/org/apache/camel/component/file/FileConsumeNotEagerMaxMessagesPerPollTest.java
----------------------------------------------------------------------
diff --git a/camel-core/src/test/java/org/apache/camel/component/file/FileConsumeNotEagerMaxMessagesPerPollTest.java b/camel-core/src/test/java/org/apache/camel/component/file/FileConsumeNotEagerMaxMessagesPerPollTest.java
index 722adde..9a05de9 100644
--- a/camel-core/src/test/java/org/apache/camel/component/file/FileConsumeNotEagerMaxMessagesPerPollTest.java
+++ b/camel-core/src/test/java/org/apache/camel/component/file/FileConsumeNotEagerMaxMessagesPerPollTest.java
@@ -27,22 +27,26 @@ import org.apache.camel.component.mock.MockEndpoint;
 public class FileConsumeNotEagerMaxMessagesPerPollTest extends ContextTestSupport {
 
     // sort by name and not eager, then we should pickup the files in order
-    private String fileUrl = "file://target/poll/?initialDelay=2000&delay=5000&"
+    private String fileUrl = "file://target/poll/?initialDelay=0&delay=10&"
             + "maxMessagesPerPoll=2&eagerMaxMessagesPerPoll=false&sortBy=file:name";
 
     @Override
     protected void setUp() throws Exception {
         deleteDirectory("target/poll");
         super.setUp();
-        template.sendBodyAndHeader(fileUrl, "CCC", Exchange.FILE_NAME, "ccc.txt");
-        template.sendBodyAndHeader(fileUrl, "AAA", Exchange.FILE_NAME, "aaa.txt");
-        template.sendBodyAndHeader(fileUrl, "BBB", Exchange.FILE_NAME, "bbb.txt");
     }
 
     public void testMaxMessagesPerPoll() throws Exception {
         MockEndpoint mock = getMockEndpoint("mock:result");
         mock.expectedBodiesReceived("AAA", "BBB");
-        mock.setResultWaitTime(4000);
+
+        template.sendBodyAndHeader(fileUrl, "CCC", Exchange.FILE_NAME, "ccc.txt");
+        template.sendBodyAndHeader(fileUrl, "AAA", Exchange.FILE_NAME, "aaa.txt");
+        template.sendBodyAndHeader(fileUrl, "BBB", Exchange.FILE_NAME, "bbb.txt");
+
+        // start route
+        context.startRoute("foo");
+
         mock.expectedPropertyReceived(Exchange.BATCH_SIZE, 2);
 
         assertMockEndpointsSatisfied();
@@ -57,7 +61,8 @@ public class FileConsumeNotEagerMaxMessagesPerPollTest extends ContextTestSuppor
     protected RouteBuilder createRouteBuilder() throws Exception {
         return new RouteBuilder() {
             public void configure() throws Exception {
-                from(fileUrl).convertBodyTo(String.class).to("mock:result");
+                from(fileUrl).routeId("foo").noAutoStartup()
+                    .convertBodyTo(String.class).to("mock:result");
             }
         };
     }

http://git-wip-us.apache.org/repos/asf/camel/blob/cc1edc91/camel-core/src/test/java/org/apache/camel/component/file/FilerConsumerDoneFileNameDeleteTest.java
----------------------------------------------------------------------
diff --git a/camel-core/src/test/java/org/apache/camel/component/file/FilerConsumerDoneFileNameDeleteTest.java b/camel-core/src/test/java/org/apache/camel/component/file/FilerConsumerDoneFileNameDeleteTest.java
index 353b019..843c078 100644
--- a/camel-core/src/test/java/org/apache/camel/component/file/FilerConsumerDoneFileNameDeleteTest.java
+++ b/camel-core/src/test/java/org/apache/camel/component/file/FilerConsumerDoneFileNameDeleteTest.java
@@ -39,7 +39,7 @@ public class FilerConsumerDoneFileNameDeleteTest extends ContextTestSupport {
         template.sendBodyAndHeader("file:target/done", "Hello World", Exchange.FILE_NAME, "hello.txt");
 
         // wait a bit and it should not pickup the written file as there are no done file
-        Thread.sleep(250);
+        Thread.sleep(50);
 
         assertMockEndpointsSatisfied();
         resetMocks();

http://git-wip-us.apache.org/repos/asf/camel/blob/cc1edc91/camel-core/src/test/java/org/apache/camel/component/file/stress/FileAsyncStressFileDropper.java
----------------------------------------------------------------------
diff --git a/camel-core/src/test/java/org/apache/camel/component/file/stress/FileAsyncStressFileDropper.java b/camel-core/src/test/java/org/apache/camel/component/file/stress/FileAsyncStressFileDropper.java
index 67ee775..903d91a 100644
--- a/camel-core/src/test/java/org/apache/camel/component/file/stress/FileAsyncStressFileDropper.java
+++ b/camel-core/src/test/java/org/apache/camel/component/file/stress/FileAsyncStressFileDropper.java
@@ -20,10 +20,12 @@ import org.apache.camel.ContextTestSupport;
 import org.apache.camel.Exchange;
 import org.apache.camel.builder.RouteBuilder;
 import org.apache.camel.component.mock.MockEndpoint;
+import org.junit.Ignore;
 
 /**
  * @version 
  */
+@Ignore("Manual test")
 public class FileAsyncStressFileDropper extends ContextTestSupport {
 
     private static int counter;

http://git-wip-us.apache.org/repos/asf/camel/blob/cc1edc91/camel-core/src/test/java/org/apache/camel/component/file/stress/FileAsyncStressManually.java
----------------------------------------------------------------------
diff --git a/camel-core/src/test/java/org/apache/camel/component/file/stress/FileAsyncStressManually.java b/camel-core/src/test/java/org/apache/camel/component/file/stress/FileAsyncStressManually.java
index 27a5766..395d22f 100644
--- a/camel-core/src/test/java/org/apache/camel/component/file/stress/FileAsyncStressManually.java
+++ b/camel-core/src/test/java/org/apache/camel/component/file/stress/FileAsyncStressManually.java
@@ -23,10 +23,12 @@ import org.apache.camel.Exchange;
 import org.apache.camel.Processor;
 import org.apache.camel.builder.RouteBuilder;
 import org.apache.camel.component.mock.MockEndpoint;
+import org.junit.Ignore;
 
 /**
  * @version 
  */
+@Ignore("Manual test")
 public class FileAsyncStressManually extends ContextTestSupport {
 
     public void testAsyncStress() throws Exception {

http://git-wip-us.apache.org/repos/asf/camel/blob/cc1edc91/camel-core/src/test/java/org/apache/camel/component/file/stress/FileAsyncStressReadLockLockFileTest.java
----------------------------------------------------------------------
diff --git a/camel-core/src/test/java/org/apache/camel/component/file/stress/FileAsyncStressReadLockLockFileTest.java b/camel-core/src/test/java/org/apache/camel/component/file/stress/FileAsyncStressReadLockLockFileTest.java
index 4aaf5a1..c44ba70 100644
--- a/camel-core/src/test/java/org/apache/camel/component/file/stress/FileAsyncStressReadLockLockFileTest.java
+++ b/camel-core/src/test/java/org/apache/camel/component/file/stress/FileAsyncStressReadLockLockFileTest.java
@@ -21,10 +21,12 @@ import java.util.Random;
 import org.apache.camel.Exchange;
 import org.apache.camel.Processor;
 import org.apache.camel.builder.RouteBuilder;
+import org.junit.Ignore;
 
 /**
  * @version 
  */
+@Ignore("Manual test")
 public class FileAsyncStressReadLockLockFileTest extends FileAsyncStressTest {
 
     @Override

http://git-wip-us.apache.org/repos/asf/camel/blob/cc1edc91/camel-core/src/test/java/org/apache/camel/component/file/stress/FileAsyncStressReadLockNoneTest.java
----------------------------------------------------------------------
diff --git a/camel-core/src/test/java/org/apache/camel/component/file/stress/FileAsyncStressReadLockNoneTest.java b/camel-core/src/test/java/org/apache/camel/component/file/stress/FileAsyncStressReadLockNoneTest.java
index f9e506f..8979dde 100644
--- a/camel-core/src/test/java/org/apache/camel/component/file/stress/FileAsyncStressReadLockNoneTest.java
+++ b/camel-core/src/test/java/org/apache/camel/component/file/stress/FileAsyncStressReadLockNoneTest.java
@@ -21,10 +21,12 @@ import java.util.Random;
 import org.apache.camel.Exchange;
 import org.apache.camel.Processor;
 import org.apache.camel.builder.RouteBuilder;
+import org.junit.Ignore;
 
 /**
  * @version 
  */
+@Ignore("Manual test")
 public class FileAsyncStressReadLockNoneTest extends FileAsyncStressTest {
 
     @Override

http://git-wip-us.apache.org/repos/asf/camel/blob/cc1edc91/camel-core/src/test/java/org/apache/camel/component/file/stress/FileAsyncStressReadLockRenameTest.java
----------------------------------------------------------------------
diff --git a/camel-core/src/test/java/org/apache/camel/component/file/stress/FileAsyncStressReadLockRenameTest.java b/camel-core/src/test/java/org/apache/camel/component/file/stress/FileAsyncStressReadLockRenameTest.java
index 41df78a..2398140 100644
--- a/camel-core/src/test/java/org/apache/camel/component/file/stress/FileAsyncStressReadLockRenameTest.java
+++ b/camel-core/src/test/java/org/apache/camel/component/file/stress/FileAsyncStressReadLockRenameTest.java
@@ -21,10 +21,12 @@ import java.util.Random;
 import org.apache.camel.Exchange;
 import org.apache.camel.Processor;
 import org.apache.camel.builder.RouteBuilder;
+import org.junit.Ignore;
 
 /**
  * @version 
  */
+@Ignore("Manual test")
 public class FileAsyncStressReadLockRenameTest extends FileAsyncStressTest {
 
     @Override

http://git-wip-us.apache.org/repos/asf/camel/blob/cc1edc91/camel-core/src/test/java/org/apache/camel/component/file/stress/FileAsyncStressTest.java
----------------------------------------------------------------------
diff --git a/camel-core/src/test/java/org/apache/camel/component/file/stress/FileAsyncStressTest.java b/camel-core/src/test/java/org/apache/camel/component/file/stress/FileAsyncStressTest.java
index 0580723..9767dea 100644
--- a/camel-core/src/test/java/org/apache/camel/component/file/stress/FileAsyncStressTest.java
+++ b/camel-core/src/test/java/org/apache/camel/component/file/stress/FileAsyncStressTest.java
@@ -23,10 +23,12 @@ import org.apache.camel.Exchange;
 import org.apache.camel.Processor;
 import org.apache.camel.builder.RouteBuilder;
 import org.apache.camel.component.mock.MockEndpoint;
+import org.junit.Ignore;
 
 /**
  * @version 
  */
+@Ignore("Manual test")
 public class FileAsyncStressTest extends ContextTestSupport {
 
     private int files = 150;

http://git-wip-us.apache.org/repos/asf/camel/blob/cc1edc91/camel-core/src/test/java/org/apache/camel/component/file/stress/FileConsumerPollManyFilesTest.java
----------------------------------------------------------------------
diff --git a/camel-core/src/test/java/org/apache/camel/component/file/stress/FileConsumerPollManyFilesTest.java b/camel-core/src/test/java/org/apache/camel/component/file/stress/FileConsumerPollManyFilesTest.java
index 329714e..4f3403e 100644
--- a/camel-core/src/test/java/org/apache/camel/component/file/stress/FileConsumerPollManyFilesTest.java
+++ b/camel-core/src/test/java/org/apache/camel/component/file/stress/FileConsumerPollManyFilesTest.java
@@ -20,10 +20,12 @@ import org.apache.camel.ContextTestSupport;
 import org.apache.camel.Exchange;
 import org.apache.camel.builder.RouteBuilder;
 import org.apache.camel.component.mock.MockEndpoint;
+import org.junit.Ignore;
 
 /**
  * @version 
  */
+@Ignore("Manual test")
 public class FileConsumerPollManyFilesTest extends ContextTestSupport {
 
     private static final int FILES = 200;

http://git-wip-us.apache.org/repos/asf/camel/blob/cc1edc91/camel-core/src/test/java/org/apache/camel/component/file/stress/FileProducerAppendManyMessagesFastTest.java
----------------------------------------------------------------------
diff --git a/camel-core/src/test/java/org/apache/camel/component/file/stress/FileProducerAppendManyMessagesFastTest.java b/camel-core/src/test/java/org/apache/camel/component/file/stress/FileProducerAppendManyMessagesFastTest.java
index c82ba03..0cf9d8c 100644
--- a/camel-core/src/test/java/org/apache/camel/component/file/stress/FileProducerAppendManyMessagesFastTest.java
+++ b/camel-core/src/test/java/org/apache/camel/component/file/stress/FileProducerAppendManyMessagesFastTest.java
@@ -25,10 +25,12 @@ import org.apache.camel.Exchange;
 import org.apache.camel.Processor;
 import org.apache.camel.builder.RouteBuilder;
 import org.apache.camel.component.mock.MockEndpoint;
+import org.junit.Ignore;
 
 /**
  *
  */
+@Ignore("Manual test")
 public class FileProducerAppendManyMessagesFastTest extends ContextTestSupport {
 
     private boolean enabled;

http://git-wip-us.apache.org/repos/asf/camel/blob/cc1edc91/camel-core/src/test/java/org/apache/camel/component/file/stress/FileProducerAppendManyMessagesTest.java
----------------------------------------------------------------------
diff --git a/camel-core/src/test/java/org/apache/camel/component/file/stress/FileProducerAppendManyMessagesTest.java b/camel-core/src/test/java/org/apache/camel/component/file/stress/FileProducerAppendManyMessagesTest.java
index 9874ace..b105698 100644
--- a/camel-core/src/test/java/org/apache/camel/component/file/stress/FileProducerAppendManyMessagesTest.java
+++ b/camel-core/src/test/java/org/apache/camel/component/file/stress/FileProducerAppendManyMessagesTest.java
@@ -22,10 +22,12 @@ import java.io.FileOutputStream;
 import org.apache.camel.ContextTestSupport;
 import org.apache.camel.builder.RouteBuilder;
 import org.apache.camel.component.mock.MockEndpoint;
+import org.junit.Ignore;
 
 /**
  *
  */
+@Ignore("Manual test")
 public class FileProducerAppendManyMessagesTest extends ContextTestSupport {
 
     private boolean enabled;


Mime
View raw message