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 2011/04/15 17:39:02 UTC
svn commit: r1092745 - in /camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms: JmsSimpleRequestReply2Test.java JmsSimpleRequestReplyFixedReplyQueueTest.java

Author: davsclaus
Date: Fri Apr 15 15:39:02 2011
New Revision: 1092745

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

Added:
    camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsSimpleRequestReplyFixedReplyQueueTest.java
      - copied, changed from r1092726, camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsSimpleRequestReply2Test.java
Modified:
    camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsSimpleRequestReply2Test.java

Modified: camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsSimpleRequestReply2Test.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsSimpleRequestReply2Test.java?rev=1092745&r1=1092744&r2=1092745&view=diff
==============================================================================
--- camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsSimpleRequestReply2Test.java (original)
+++ camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsSimpleRequestReply2Test.java Fri Apr 15 15:39:02 2011
@@ -47,7 +47,7 @@ public class JmsSimpleRequestReply2Test 
     public void testWithInOut() throws Exception {
         getMockEndpoint("mock:result").expectedBodiesReceived("Hello World");
 
-        // send an InOnly
+        // send an InOut
         String out = template.requestBody("direct:start", "World", String.class);
         assertEquals("Hello World", out);
 

Copied: camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsSimpleRequestReplyFixedReplyQueueTest.java (from r1092726, camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsSimpleRequestReply2Test.java)
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsSimpleRequestReplyFixedReplyQueueTest.java?p2=camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsSimpleRequestReplyFixedReplyQueueTest.java&p1=camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsSimpleRequestReply2Test.java&r1=1092726&r2=1092745&rev=1092745&view=diff
==============================================================================
--- camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsSimpleRequestReply2Test.java (original)
+++ camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsSimpleRequestReplyFixedReplyQueueTest.java Fri Apr 15 15:39:02 2011
@@ -18,7 +18,6 @@ package org.apache.camel.component.jms;
 
 import javax.jms.ConnectionFactory;
 
-import org.apache.activemq.ActiveMQConnectionFactory;
 import org.apache.camel.CamelContext;
 import org.apache.camel.builder.RouteBuilder;
 import org.apache.camel.test.junit4.CamelTestSupport;
@@ -29,7 +28,7 @@ import static org.apache.camel.component
 /**
  * A simple request / reply test
  */
-public class JmsSimpleRequestReply2Test extends CamelTestSupport {
+public class JmsSimpleRequestReplyFixedReplyQueueTest extends CamelTestSupport {
 
     protected String componentName = "activemq";
 
@@ -47,7 +46,7 @@ public class JmsSimpleRequestReply2Test 
     public void testWithInOut() throws Exception {
         getMockEndpoint("mock:result").expectedBodiesReceived("Hello World");
 
-        // send an InOnly
+        // send an InOut
         String out = template.requestBody("direct:start", "World", String.class);
         assertEquals("Hello World", out);
 
@@ -67,7 +66,7 @@ public class JmsSimpleRequestReply2Test 
         return new RouteBuilder() {
             public void configure() throws Exception {
                 from("direct:start")
-                    .inOut("activemq:queue:foo")
+                    .inOut("activemq:queue:foo?replyTo=queue:bar")
                     .to("mock:result");
 
                 from("activemq:queue:foo")