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