camel-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ningji...@apache.org
Subject svn commit: r729257 - /activemq/camel/trunk/camel-core/src/test/java/org/apache/camel/component/file/FileExclusiveReadRenameStrategyTest.java
Date Wed, 24 Dec 2008 07:04:55 GMT
Author: ningjiang
Date: Tue Dec 23 23:04:55 2008
New Revision: 729257

URL: http://svn.apache.org/viewvc?rev=729257&view=rev
Log:
Try to fixed the FileExclusiveReadRenameStrategyTest failures in Linux Box

Modified:
    activemq/camel/trunk/camel-core/src/test/java/org/apache/camel/component/file/FileExclusiveReadRenameStrategyTest.java

Modified: activemq/camel/trunk/camel-core/src/test/java/org/apache/camel/component/file/FileExclusiveReadRenameStrategyTest.java
URL: http://svn.apache.org/viewvc/activemq/camel/trunk/camel-core/src/test/java/org/apache/camel/component/file/FileExclusiveReadRenameStrategyTest.java?rev=729257&r1=729256&r2=729257&view=diff
==============================================================================
--- activemq/camel/trunk/camel-core/src/test/java/org/apache/camel/component/file/FileExclusiveReadRenameStrategyTest.java
(original)
+++ activemq/camel/trunk/camel-core/src/test/java/org/apache/camel/component/file/FileExclusiveReadRenameStrategyTest.java
Tue Dec 23 23:04:55 2008
@@ -54,6 +54,9 @@
     }
 
     public void testPollFileWhileSlowFileIsBeingWritten() throws Exception {
+        deleteDirectory("./target/exclusiveread");
+        createDirectory("./target/exclusiveread/slowfile");
+        
         context.addRoutes(new RouteBuilder() {
             @Override
             public void configure() throws Exception {
@@ -62,9 +65,7 @@
             }
         });
         context.start();
-
-        deleteDirectory("./target/exclusiveread");
-        createDirectory("./target/exclusiveread/slowfile");
+       
         MockEndpoint mock = getMockEndpoint("mock:result");
         mock.expectedMessageCount(1);
         mock.expectedBodiesReceived("Hello WorldLine #0Line #1Line #2Bye World");
@@ -77,6 +78,9 @@
     }
 
     public void testPollFileWhileSlowFileIsBeingWrittenWithTimeout() throws Exception {
+        deleteDirectory("./target/exclusiveread");
+        createDirectory("./target/exclusiveread/slowfile");
+        
         context.addRoutes(new RouteBuilder() {
             @Override
             public void configure() throws Exception {
@@ -85,9 +89,7 @@
             }
         });
         context.start();
-
-        deleteDirectory("./target/exclusiveread");
-        createDirectory("./target/exclusiveread/slowfile");
+        
         MockEndpoint mock = getMockEndpoint("mock:result");
         mock.expectedMessageCount(0);
         mock.setMinimumResultWaitTime(2000);
@@ -100,6 +102,8 @@
     }
 
     public void testPollFileWhileSlowFileIsBeingWrittenWithTimeoutAndNoop() throws Exception
{
+        deleteDirectory("./target/exclusiveread");
+        createDirectory("./target/exclusiveread/slowfile");
         // to test that if noop and thus idempotent we will retry to consume the file
         // the 2nd. time since the first time we could not get the read lock due timeout
         // so the file should only be marked in the idempotent repository if we could process
it
@@ -111,11 +115,9 @@
             }
         });
         context.start();
-
-        deleteDirectory("./target/exclusiveread");
-        createDirectory("./target/exclusiveread/slowfile");
+        
         MockEndpoint mock = getMockEndpoint("mock:result");
-        mock.expectedMessageCount(1);
+        mock.expectedMessageCount(1);        
         mock.setMinimumResultWaitTime(3000);
         mock.setResultWaitTime(5000);
 



Mime
View raw message