svn commit: r740641 - /camel/trunk/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/HttpToFileTest.java

[da...@apache.org]

Author: davsclaus
Date: Wed Feb  4 07:12:30 2009
New Revision: 740641

URL: http://svn.apache.org/viewvc?rev=740641&view=rev
Log:
Fixed occasional failing unit test

Modified:
    camel/trunk/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/HttpToFileTest.java

Modified: camel/trunk/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/HttpToFileTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/HttpToFileTest.java?rev=740641&r1=740640&r2=740641&view=diff
==============================================================================
--- camel/trunk/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/HttpToFileTest.java (original)
+++ camel/trunk/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/HttpToFileTest.java Wed Feb  4 07:12:30 2009
@@ -21,6 +21,7 @@
 import org.apache.camel.ContextTestSupport;
 import org.apache.camel.builder.RouteBuilder;
 import org.apache.camel.component.file.FileComponent;
+import org.apache.camel.component.mock.MockEndpoint;
 import org.apache.camel.converter.IOConverter;
 
 /**
@@ -29,13 +30,18 @@
 public class HttpToFileTest extends ContextTestSupport {
 
     public void testToJettyAndSaveToFile() throws Exception {
+        MockEndpoint mock = getMockEndpoint("mock:result");
+        mock.expectedBodiesReceived("Hello World");
+
         Object out = template.sendBody("http://localhost:8080/myworld", "Hello World");
 
         String response = context.getTypeConverter().convertTo(String.class, out);
         assertEquals("Response from Jetty", "We got the file", response);
 
+        assertMockEndpointsSatisfied();
+
         // give file some time to save
-        Thread.sleep(2000);
+        Thread.sleep(500);
 
         File file = new File("./target/myworld/hello.txt");
         file = file.getAbsoluteFile();
@@ -48,7 +54,6 @@
     @Override
     protected void setUp() throws Exception {
         deleteDirectory("target/myworld");
-        disableJMX();
         super.setUp();
     }
 
@@ -62,7 +67,8 @@
                 from("seda:in")
                     .setHeader(FileComponent.HEADER_FILE_NAME, constant("hello.txt"))
                     .convertBodyTo(String.class)
-                    .to("file://target/myworld?append=false");
+                    .to("file://target/myworld/")
+                    .to("mock:result");
             }
         };
     }