svn commit: r1205372 - /camel/trunk/tests/camel-itest/src/test/java/org/apache/camel/itest/jms/JmsHttpJmsTest.java

[ningjiang]

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