svn commit: r1424337 - /camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsInOutNonPersistentTest.java

[davsclaus]

Author: davsclaus
Date: Thu Dec 20 05:56:31 2012
New Revision: 1424337

URL: http://svn.apache.org/viewvc?rev=1424337&view=rev
Log:
Added test for non persistent request/reply over jms

Added:
    
camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsInOutNonPersistentTest.java
      - copied, changed from r1424292, 
camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsInOnlyWithReplyToNotPreservedTest.java

Copied: 
camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsInOutNonPersistentTest.java
 (from r1424292, 
camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsInOnlyWithReplyToNotPreservedTest.java)
URL: 
http://svn.apache.org/viewvc/camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsInOutNonPersistentTest.java?p2=camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsInOutNonPersistentTest.java&p1=camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsInOnlyWithReplyToNotPreservedTest.java&r1=1424292&r2=1424337&rev=1424337&view=diff
==============================================================================
--- 
camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsInOnlyWithReplyToNotPreservedTest.java
 (original)
+++ 
camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsInOutNonPersistentTest.java
 Thu Dec 20 05:56:31 2012
@@ -17,6 +17,7 @@
 package org.apache.camel.component.jms;
 
 import javax.jms.ConnectionFactory;
+import javax.jms.DeliveryMode;
 
 import org.apache.camel.CamelContext;
 import org.apache.camel.builder.RouteBuilder;
@@ -28,20 +29,19 @@ import static org.apache.camel.component
 /**
  * @version 
  */
-public class JmsInOnlyWithReplyToNotPreservedTest extends CamelTestSupport {
+public class JmsInOutNonPersistentTest extends CamelTestSupport {
 
     @Test
-    public void testSendInOnlyWithReplyTo() throws Exception {
+    public void testInOutNonPersistent() throws Exception {
         getMockEndpoint("mock:foo").expectedBodiesReceived("World");
-        getMockEndpoint("mock:done").expectedBodiesReceived("World");
+        getMockEndpoint("mock:foo").expectedHeaderReceived("JMSDeliveryMode", 
DeliveryMode.NON_PERSISTENT);
+        getMockEndpoint("mock:done").expectedBodiesReceived("Bye World");
+        getMockEndpoint("mock:done").expectedHeaderReceived("JMSDeliveryMode", 
DeliveryMode.NON_PERSISTENT);
 
-        template.sendBody("direct:start", "World");
+        String reply = template.requestBody("direct:start", "World", 
String.class);
+        assertEquals("Bye World", reply);
 
         assertMockEndpointsSatisfied();
-
-        // there should be no messages on the bar queue
-        Object msg = consumer.receiveBody("activemq:queue:bar", 1000);
-        assertNull("Should be no message on bar queue", msg);
     }
 
     protected CamelContext createCamelContext() throws Exception {
@@ -57,10 +57,10 @@ public class JmsInOnlyWithReplyToNotPres
             @Override
             public void configure() throws Exception {
                 from("direct:start")
-                    .to("activemq:queue:foo?replyTo=queue:bar")
-                    .to("mock:done");
+                    
.to("activemq:queue:foo?replyTo=queue:bar&deliveryPersistent=false")
+                    .to("log:done?showAll=true", "mock:done");
 
-                from("activemq:queue:foo")
+                
from("activemq:queue:foo?replyToDeliveryPersistent=false&preserveMessageQos=true")
                     .to("log:foo?showAll=true", "mock:foo")
                     .transform(body().prepend("Bye "));
             }