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")