You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by cm...@apache.org on 2012/09/09 13:02:29 UTC
svn commit: r1382449 -
/camel/trunk/camel-core/src/test/java/org/apache/camel/component/file/FromFilePollThirdTimeOkTest.java
Author: cmueller
Date: Sun Sep 9 11:02:29 2012
New Revision: 1382449
URL: http://svn.apache.org/viewvc?rev=1382449&view=rev
Log:
small code enhancement for a test which fails randomly on slow CI server
Modified:
camel/trunk/camel-core/src/test/java/org/apache/camel/component/file/FromFilePollThirdTimeOkTest.java
Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/component/file/FromFilePollThirdTimeOkTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/component/file/FromFilePollThirdTimeOkTest.java?rev=1382449&r1=1382448&r2=1382449&view=diff
==============================================================================
--- camel/trunk/camel-core/src/test/java/org/apache/camel/component/file/FromFilePollThirdTimeOkTest.java (original)
+++ camel/trunk/camel-core/src/test/java/org/apache/camel/component/file/FromFilePollThirdTimeOkTest.java Sun Sep 9 11:02:29 2012
@@ -24,9 +24,6 @@ import org.apache.camel.Processor;
import org.apache.camel.builder.NotifyBuilder;
import org.apache.camel.builder.RouteBuilder;
-/**
- * @version
- */
public class FromFilePollThirdTimeOkTest extends ContextTestSupport {
private static int counter;
@@ -46,31 +43,30 @@ public class FromFilePollThirdTimeOkTest
getMockEndpoint("mock:result").expectedBodiesReceived(body);
assertMockEndpointsSatisfied();
- notify.matchesMockWaitTime();
-
+ assertTrue(notify.matchesMockWaitTime());
assertEquals(3, counter);
// assert the file is deleted
- File file = new File("./target/deletefile/hello.txt");
- file = file.getAbsoluteFile();
+ File file = new File("./target/deletefile/hello.txt").getAbsoluteFile();
assertFalse("The file should have been deleted", file.exists());
}
protected RouteBuilder createRouteBuilder() throws Exception {
return new RouteBuilder() {
public void configure() throws Exception {
- from("file://target/deletefile?delete=true&initialDelay=0&delay=10").process(new Processor() {
- public void process(Exchange exchange) throws Exception {
- counter++;
- if (counter < 3) {
- // file should exists
- File file = new File("./target/deletefile/hello.txt");
- file = file.getAbsoluteFile();
- assertTrue("The file should NOT have been deleted", file.exists());
- throw new IllegalArgumentException("Forced by unittest");
+ from("file://target/deletefile?delete=true&initialDelay=0&delay=10")
+ .process(new Processor() {
+ public void process(Exchange exchange) throws Exception {
+ counter++;
+ if (counter < 3) {
+ // file should exists
+ File file = new File("./target/deletefile/hello.txt").getAbsoluteFile();
+ assertTrue("The file should NOT have been deleted", file.exists());
+ throw new IllegalArgumentException("Forced by unittest");
+ }
}
- }
- }).to("mock:result");
+ })
+ .to("mock:result");
}
};
}