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 <davscl...@apache.org> Authored: Sat Jul 8 11:07:06 2017 +0200 Committer: Claus Ibsen <davscl...@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;
