You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2011/01/20 07:42:55 UTC
svn commit: r1061132 -
/camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsInOnlyWithReplyToTest.java
Author: davsclaus
Date: Thu Jan 20 06:42:55 2011
New Revision: 1061132
URL: http://svn.apache.org/viewvc?rev=1061132&view=rev
Log:
Fixed test
Modified:
camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsInOnlyWithReplyToTest.java
Modified: camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsInOnlyWithReplyToTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsInOnlyWithReplyToTest.java?rev=1061132&r1=1061131&r2=1061132&view=diff
==============================================================================
--- camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsInOnlyWithReplyToTest.java (original)
+++ camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsInOnlyWithReplyToTest.java Thu Jan 20 06:42:55 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;
@@ -62,7 +61,9 @@ public class JmsInOnlyWithReplyToTest ex
.to("log:foo?showAll=true", "mock:foo")
.transform(body().prepend("Bye "));
- from("activemq:queue:bar")
+ // we should disable reply to to avoid sending the message back to our self
+ // after we have consumed it
+ from("activemq:queue:bar?disableReplyTo=true")
.to("log:bar?showAll=true", "mock:bar");
}
};