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 2009/05/10 11:08:56 UTC

svn commit: r773318 - /camel/trunk/tests/camel-itest/src/test/java/org/apache/camel/itest/async/HttpSyncTest.java

Author: davsclaus
Date: Sun May 10 09:08:56 2009
New Revision: 773318

URL: http://svn.apache.org/viewvc?rev=773318&view=rev
Log:
CAMEL-1572: Added another sync sample for comparision with async for show and tell.

Added:
    camel/trunk/tests/camel-itest/src/test/java/org/apache/camel/itest/async/HttpSyncTest.java
      - copied, changed from r773224, camel/trunk/tests/camel-itest/src/test/java/org/apache/camel/itest/async/HttpAsyncTest.java

Copied: camel/trunk/tests/camel-itest/src/test/java/org/apache/camel/itest/async/HttpSyncTest.java (from r773224, camel/trunk/tests/camel-itest/src/test/java/org/apache/camel/itest/async/HttpAsyncTest.java)
URL: http://svn.apache.org/viewvc/camel/trunk/tests/camel-itest/src/test/java/org/apache/camel/itest/async/HttpSyncTest.java?p2=camel/trunk/tests/camel-itest/src/test/java/org/apache/camel/itest/async/HttpSyncTest.java&p1=camel/trunk/tests/camel-itest/src/test/java/org/apache/camel/itest/async/HttpAsyncTest.java&r1=773224&r2=773318&rev=773318&view=diff
==============================================================================
--- camel/trunk/tests/camel-itest/src/test/java/org/apache/camel/itest/async/HttpAsyncTest.java (original)
+++ camel/trunk/tests/camel-itest/src/test/java/org/apache/camel/itest/async/HttpSyncTest.java Sun May 10 09:08:56 2009
@@ -25,34 +25,22 @@
 /**
  * @version $Revision$
  */
-public class HttpAsyncTest extends ContextTestSupport {
+public class HttpSyncTest extends ContextTestSupport {
 
-    public void testAsyncAndSyncAtSameTimeWithHttp() throws Exception {
+    public void testSyncAndSyncAtSameTimeWithHttp() throws Exception {
         // START SNIPPET: e2
         MockEndpoint mock = getMockEndpoint("mock:result");
-        // We expect the name job to be faster than the async job even though the async job
-        // was started first
-        mock.expectedBodiesReceived("Claus", "Bye World");
+        // We expect the http job to complete before the name job
+        mock.expectedBodiesReceived("Bye World", "Claus");
 
-        // Send a async request/reply message to the http endpoint
-        Future future = template.asyncRequestBody("http://0.0.0.0:9080/myservice", "Hello World");
+        // Send a sync request/reply message to the http endpoint
+        String response = template.requestBody("http://0.0.0.0:9080/myservice", "Hello World", String.class);
+        assertEquals("Bye World", response);
 
-        // We got the future so in the meantime we can do other stuff, as this is Camel
-        // so lets invoke another request/reply route but this time is synchronous
+        // Send a sync request/reply message to the direct endpoint
         String name = template.requestBody("direct:name", "Give me a name", String.class);
         assertEquals("Claus", name);
 
-        // Okay we got a name and we have done some other work at the same time
-        // the async route is running, but now its about time to wait and get
-        // get the response from the async task
-
-        // We use the extract future body to get the response from the future
-        // (waiting if needed) and then return a string body response.
-        // This allows us to do this in a single code line instead of using the
-        // JDK Future API to get hold of it, but you can also use that if you want
-        String response = template.extractFutureBody(future, String.class);
-        assertEquals("Bye World", response);
-
         assertMockEndpointsSatisfied();
         // END SNIPPET: e2
     }
@@ -78,4 +66,4 @@
         };
     }
 
-}
+}
\ No newline at end of file