You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ni...@apache.org on 2010/07/07 10:00:54 UTC
svn commit: r961283 -
/camel/trunk/components/camel-stream/src/test/java/org/apache/camel/component/stream/ScanStreamFileTest.java
Author: ningjiang
Date: Wed Jul 7 08:00:54 2010
New Revision: 961283
URL: http://svn.apache.org/viewvc?rev=961283&view=rev
Log:
Try to fixed the unit test error of ScanStreamFileTest
Modified:
camel/trunk/components/camel-stream/src/test/java/org/apache/camel/component/stream/ScanStreamFileTest.java
Modified: camel/trunk/components/camel-stream/src/test/java/org/apache/camel/component/stream/ScanStreamFileTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-stream/src/test/java/org/apache/camel/component/stream/ScanStreamFileTest.java?rev=961283&r1=961282&r2=961283&view=diff
==============================================================================
--- camel/trunk/components/camel-stream/src/test/java/org/apache/camel/component/stream/ScanStreamFileTest.java (original)
+++ camel/trunk/components/camel-stream/src/test/java/org/apache/camel/component/stream/ScanStreamFileTest.java Wed Jul 7 08:00:54 2010
@@ -54,10 +54,10 @@ public class ScanStreamFileTest extends
fos.write("Hello\n".getBytes());
Thread.sleep(150);
fos.write("World\n".getBytes());
-
+ fos.close();
+
assertMockEndpointsSatisfied();
- fos.close();
}
@Test
@@ -66,7 +66,7 @@ public class ScanStreamFileTest extends
mock.expectedBodiesReceived("Hello", "there", "World", "!");
FileOutputStream fos = refreshFile(null);
- fos.write("Hello\n".getBytes());
+ fos.write("Hello\n".getBytes());
Thread.sleep(150);
fos.write("there\n".getBytes());
fos = refreshFile(fos);
@@ -76,10 +76,10 @@ public class ScanStreamFileTest extends
fos = refreshFile(fos);
Thread.sleep(150);
fos.write("!\n".getBytes());
-
+ fos.close();
assertMockEndpointsSatisfied();
- fos.close();
+
}
private FileOutputStream refreshFile(FileOutputStream fos) throws Exception {