svn commit: r961283 - /camel/trunk/components/camel-stream/src/test/java/org/apache/camel/component/stream/ScanStreamFileTest.java

[ningjiang]

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 {