svn commit: r1205388 - in /camel/branches/camel-2.8.x: ./ tests/camel-itest/src/test/java/org/apache/camel/itest/jms/JmsHttpJmsTest.java

[ningjiang]

Author: ningjiang
Date: Wed Nov 23 13:10:52 2011
New Revision: 1205388

URL: http://svn.apache.org/viewvc?rev=1205388&view=rev
Log:
Merged revisions 1205372 via svnmerge from 
https://svn.apache.org/repos/asf/camel/trunk

........
  r1205372 | ningjiang | 2011-11-23 19:41:37 +0800 (Wed, 23 Nov 2011) | 1 line
  
  Added the unit test of sending request/reply between the jms endpoint and 
jetty endpoint
........

Modified:
    camel/branches/camel-2.8.x/   (props changed)
    
camel/branches/camel-2.8.x/tests/camel-itest/src/test/java/org/apache/camel/itest/jms/JmsHttpJmsTest.java

Propchange: camel/branches/camel-2.8.x/
------------------------------------------------------------------------------
--- svn:mergeinfo (original)
+++ svn:mergeinfo Wed Nov 23 13:10:52 2011
@@ -1 +1 @@
-/camel/trunk:1202148,1202167,1202204-1202206,1202215,1202223,1202659,1202685,1203879,1203978,1204338,1205124
+/camel/trunk:1202148,1202167,1202204-1202206,1202215,1202223,1202659,1202685,1203879,1203978,1204338,1205124,1205372

Propchange: camel/branches/camel-2.8.x/
------------------------------------------------------------------------------
Binary property 'svnmerge-integrated' - no diff available.

Modified: 
camel/branches/camel-2.8.x/tests/camel-itest/src/test/java/org/apache/camel/itest/jms/JmsHttpJmsTest.java
URL: 
http://svn.apache.org/viewvc/camel/branches/camel-2.8.x/tests/camel-itest/src/test/java/org/apache/camel/itest/jms/JmsHttpJmsTest.java?rev=1205388&r1=1205387&r2=1205388&view=diff
==============================================================================
--- 
camel/branches/camel-2.8.x/tests/camel-itest/src/test/java/org/apache/camel/itest/jms/JmsHttpJmsTest.java
 (original)
+++ 
camel/branches/camel-2.8.x/tests/camel-itest/src/test/java/org/apache/camel/itest/jms/JmsHttpJmsTest.java
 Wed Nov 23 13:10:52 2011
@@ -39,6 +39,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");
 
@@ -49,7 +50,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
@@ -59,6 +74,8 @@ public class JmsHttpJmsTest extends Came
                 
from("jms:in").to("http://localhost:9080/myservice";).convertBodyTo(String.class).to("jms:out",
 "mock:result");
 
                 
from("jetty:http://0.0.0.0:9080/myservice";).transform().constant("Bye World");
+                from("jms:reply").to("http://localhost:9080/myservice";);
+                
             }
         };
     }
@@ -74,4 +91,4 @@ public class JmsHttpJmsTest extends Came
         return answer;
     }
 
-}
\ No newline at end of file
+}