You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ni...@apache.org on 2011/11/23 12:41:38 UTC
svn commit: r1205372 -
/camel/trunk/tests/camel-itest/src/test/java/org/apache/camel/itest/jms/JmsHttpJmsTest.java
Author: ningjiang
Date: Wed Nov 23 11:41:37 2011
New Revision: 1205372
URL: http://svn.apache.org/viewvc?rev=1205372&view=rev
Log:
Added the unit test of sending request/reply between the jms endpoint and jetty endpoint
Modified:
camel/trunk/tests/camel-itest/src/test/java/org/apache/camel/itest/jms/JmsHttpJmsTest.java
Modified: camel/trunk/tests/camel-itest/src/test/java/org/apache/camel/itest/jms/JmsHttpJmsTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/tests/camel-itest/src/test/java/org/apache/camel/itest/jms/JmsHttpJmsTest.java?rev=1205372&r1=1205371&r2=1205372&view=diff
==============================================================================
--- camel/trunk/tests/camel-itest/src/test/java/org/apache/camel/itest/jms/JmsHttpJmsTest.java (original)
+++ camel/trunk/tests/camel-itest/src/test/java/org/apache/camel/itest/jms/JmsHttpJmsTest.java Wed Nov 23 11:41:37 2011
@@ -42,6 +42,7 @@ public class JmsHttpJmsTest extends Came
public void testJmsHttpJms() throws Exception {
MockEndpoint mock = getMockEndpoint("mock:result");
mock.expectedMessageCount(1);
+ mock.expectedBodiesReceived("Bye World");
template.sendBody("jms:in", "Hello World");
@@ -52,7 +53,21 @@ public class JmsHttpJmsTest extends Came
}
});
- assertMockEndpointsSatisfied();
+ mock.assertIsSatisfied();
+ }
+
+ @Test
+ public void testResultReplyJms() throws Exception {
+ Exchange exchange = template.request("jms:reply?replyTo=bar", new Processor() {
+ public void process(Exchange exchange) throws Exception {
+ exchange.getIn().setBody("Hello World");
+ }
+ });
+ assertEquals("Bye World", exchange.getOut().getBody(String.class));
+ assertTrue("Should have headers", exchange.getOut().hasHeaders());
+ assertEquals("queue://bar", exchange.getOut().getHeader("JMSReplyTo", String.class));
+
+
}
@Override
@@ -63,6 +78,8 @@ public class JmsHttpJmsTest extends Came
public void configure() {
from("jms:in").to("http://localhost:" + port + "/myservice").convertBodyTo(String.class).to("jms:out", "mock:result");
+ from("jms:reply").to("http://localhost:" + port + "/myservice");
+
from("jetty:http://0.0.0.0:" + port + "/myservice").transform().constant("Bye World");
}
};