svn commit: r960882 - /camel/trunk/camel-core/src/test/java/org/apache/camel/component/seda/DirectRequestReplyAndSedaInOnlyTest.java

[da...@apache.org]

Author: davsclaus
Date: Tue Jul  6 12:00:36 2010
New Revision: 960882

URL: http://svn.apache.org/viewvc?rev=960882&view=rev
Log:
Added unit test based on user forum issue

Added:
    camel/trunk/camel-core/src/test/java/org/apache/camel/component/seda/DirectRequestReplyAndSedaInOnlyTest.java   (contents, props changed)
      - copied, changed from r960875, camel/trunk/camel-core/src/test/java/org/apache/camel/component/seda/SedaInOutTest.java

Copied: camel/trunk/camel-core/src/test/java/org/apache/camel/component/seda/DirectRequestReplyAndSedaInOnlyTest.java (from r960875, camel/trunk/camel-core/src/test/java/org/apache/camel/component/seda/SedaInOutTest.java)
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/component/seda/DirectRequestReplyAndSedaInOnlyTest.java?p2=camel/trunk/camel-core/src/test/java/org/apache/camel/component/seda/DirectRequestReplyAndSedaInOnlyTest.java&p1=camel/trunk/camel-core/src/test/java/org/apache/camel/component/seda/SedaInOutTest.java&r1=960875&r2=960882&rev=960882&view=diff
==============================================================================
--- camel/trunk/camel-core/src/test/java/org/apache/camel/component/seda/SedaInOutTest.java (original)
+++ camel/trunk/camel-core/src/test/java/org/apache/camel/component/seda/DirectRequestReplyAndSedaInOnlyTest.java Tue Jul  6 12:00:36 2010
@@ -22,13 +22,14 @@ import org.apache.camel.builder.RouteBui
 /**
  * @version $Revision$
  */
-public class SedaInOutTest extends ContextTestSupport {
+public class DirectRequestReplyAndSedaInOnlyTest extends ContextTestSupport {
 
     public void testInOut() throws Exception {
-        getMockEndpoint("mock:result").expectedBodiesReceived("Bye World");
+        getMockEndpoint("mock:log").expectedBodiesReceived("Logging: Bye World");
 
         String out = template.requestBody("direct:start", "Hello World", String.class);
         assertEquals("Bye World", out);
+        log.info("Got reply " + out);
 
         assertMockEndpointsSatisfied();
     }
@@ -38,9 +39,12 @@ public class SedaInOutTest extends Conte
         return new RouteBuilder() {
             @Override
             public void configure() throws Exception {
-                from("direct:start").to("seda:foo");
+                // send the message as InOnly to SEDA as we want to continue routing
+                // (as we don't want to do request/reply over SEDA)
+                // In EIP patterns the WireTap pattern is what this would be
+                from("direct:start").transform(constant("Bye World")).inOnly("seda:log");
 
-                from("seda:foo").transform(constant("Bye World")).to("mock:result");
+                from("seda:log").delay(1000).transform(body().prepend("Logging: ")).to("log:log", "mock:log");
             }
         };
     }

Propchange: camel/trunk/camel-core/src/test/java/org/apache/camel/component/seda/DirectRequestReplyAndSedaInOnlyTest.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: camel/trunk/camel-core/src/test/java/org/apache/camel/component/seda/DirectRequestReplyAndSedaInOnlyTest.java
------------------------------------------------------------------------------
    svn:keywords = Rev Date