You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2010/04/12 07:10:44 UTC
svn commit: r933097 - in
/camel/trunk/camel-core/src/test/java/org/apache/camel/component/file:
FileConcurrentAggregateBatchConsumerTest.java FileConcurrentTest.java
FileConsumerFailureHandledTest.java
Author: davsclaus
Date: Mon Apr 12 05:10:43 2010
New Revision: 933097
URL: http://svn.apache.org/viewvc?rev=933097&view=rev
Log:
Fixed test on other boxes.
Modified:
camel/trunk/camel-core/src/test/java/org/apache/camel/component/file/FileConcurrentAggregateBatchConsumerTest.java
camel/trunk/camel-core/src/test/java/org/apache/camel/component/file/FileConcurrentTest.java
camel/trunk/camel-core/src/test/java/org/apache/camel/component/file/FileConsumerFailureHandledTest.java
Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/component/file/FileConcurrentAggregateBatchConsumerTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/component/file/FileConcurrentAggregateBatchConsumerTest.java?rev=933097&r1=933096&r2=933097&view=diff
==============================================================================
--- camel/trunk/camel-core/src/test/java/org/apache/camel/component/file/FileConcurrentAggregateBatchConsumerTest.java (original)
+++ camel/trunk/camel-core/src/test/java/org/apache/camel/component/file/FileConcurrentAggregateBatchConsumerTest.java Mon Apr 12 05:10:43 2010
@@ -94,8 +94,8 @@ public class FileConcurrentAggregateBatc
long start = System.currentTimeMillis();
MockEndpoint result = getMockEndpoint("mock:result");
- // should be ordered
- result.expectedBodiesReceived("A+C+E+G+I", "B+D+F+H+J");
+ // should be ordered in the body, but the files can be loaded in different order per OS
+ result.expectedBodiesReceivedInAnyOrder("A+C+E+G+I", "B+D+F+H+J");
assertMockEndpointsSatisfied();
Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/component/file/FileConcurrentTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/component/file/FileConcurrentTest.java?rev=933097&r1=933096&r2=933097&view=diff
==============================================================================
--- camel/trunk/camel-core/src/test/java/org/apache/camel/component/file/FileConcurrentTest.java (original)
+++ camel/trunk/camel-core/src/test/java/org/apache/camel/component/file/FileConcurrentTest.java Mon Apr 12 05:10:43 2010
@@ -131,8 +131,8 @@ public class FileConcurrentTest extends
long start = System.currentTimeMillis();
MockEndpoint result = getMockEndpoint("mock:result");
- // should be ordered
- result.expectedBodiesReceived("A+C+E+G+I", "B+D+F+H+J");
+ // should be ordered in the body, but the files can be loaded in different order per OS
+ result.expectedBodiesReceivedInAnyOrder("A+C+E+G+I", "B+D+F+H+J");
assertMockEndpointsSatisfied();
Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/component/file/FileConsumerFailureHandledTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/component/file/FileConsumerFailureHandledTest.java?rev=933097&r1=933096&r2=933097&view=diff
==============================================================================
--- camel/trunk/camel-core/src/test/java/org/apache/camel/component/file/FileConsumerFailureHandledTest.java (original)
+++ camel/trunk/camel-core/src/test/java/org/apache/camel/component/file/FileConsumerFailureHandledTest.java Mon Apr 12 05:10:43 2010
@@ -34,7 +34,7 @@ public class FileConsumerFailureHandledT
@Override
protected void setUp() throws Exception {
- deleteDirectory("target/messages");
+ deleteDirectory("target/messages/input");
super.setUp();
}
@@ -42,13 +42,13 @@ public class FileConsumerFailureHandledT
MockEndpoint mock = getMockEndpoint("mock:valid");
mock.expectedBodiesReceived("Hello Paris");
- template.sendBodyAndHeader("file:target/messages/input/?delete=true&delay=5000", "Paris", Exchange.FILE_NAME, "paris.txt");
+ template.sendBodyAndHeader("file:target/messages/input/", "Paris", Exchange.FILE_NAME, "paris.txt");
mock.assertIsSatisfied();
// sleep otherwise the file assertions below could fail
Thread.sleep(200);
- asserFiles("paris.txt", true);
+ assertFiles("paris.txt", true);
}
public void testLondon() throws Exception {
@@ -56,14 +56,14 @@ public class FileConsumerFailureHandledT
// we get the original input so its not Hello London but only London
mock.expectedBodiesReceived("London");
- template.sendBodyAndHeader("file:target/messages/input/?delete=true&delay=5000", "London", Exchange.FILE_NAME, "london.txt");
+ template.sendBodyAndHeader("file:target/messages/input/", "London", Exchange.FILE_NAME, "london.txt");
mock.assertIsSatisfied();
// sleep otherwise the file assertions below could fail
Thread.sleep(200);
- // london should be delated as we have failure handled it
- asserFiles("london.txt", true);
+ // london should be deleted as we have failure handled it
+ assertFiles("london.txt", true);
}
public void testDublin() throws Exception {
@@ -71,14 +71,14 @@ public class FileConsumerFailureHandledT
// we get the original input so its not Hello London but only London
mock.expectedBodiesReceived("Dublin");
- template.sendBodyAndHeader("file:target/messages/input/?delete=true&delay=5000", "Dublin", Exchange.FILE_NAME, "dublin.txt");
+ template.sendBodyAndHeader("file:target/messages/input/", "Dublin", Exchange.FILE_NAME, "dublin.txt");
mock.assertIsSatisfied();
// sleep otherwise the file assertions below could fail
Thread.sleep(200);
// dublin should NOT be deleted, but should be retired on next consumer
- asserFiles("dublin.txt", false);
+ assertFiles("dublin.txt", false);
}
public void testMadrid() throws Exception {
@@ -86,18 +86,18 @@ public class FileConsumerFailureHandledT
// we get the original input so its not Hello London but only London
mock.expectedBodiesReceived("Madrid");
- template.sendBodyAndHeader("file:target/messages/input/?delete=true&delay=5000", "Madrid", Exchange.FILE_NAME, "madrid.txt");
+ template.sendBodyAndHeader("file:target/messages/input/", "Madrid", Exchange.FILE_NAME, "madrid.txt");
mock.assertIsSatisfied();
// sleep otherwise the file assertions below could fail
Thread.sleep(200);
// madrid should NOT be deleted, but should be retired on next consumer
- asserFiles("madrid.txt", false);
+ assertFiles("madrid.txt", false);
}
- private static void asserFiles(String filename, boolean deleted) throws InterruptedException {
- // file should be deleted as deleted=true in parameter in the route below
+ private static void assertFiles(String filename, boolean deleted) throws InterruptedException {
+ // file should be deleted as delete=true in parameter in the route below
File file = new File("target/messages/input/" + filename);
assertEquals("File " + filename + " should be deleted: " + deleted, deleted, !file.exists());