Fixed test when using AMQ 5.9.0
Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/0fc72e85 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/0fc72e85 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/0fc72e85 Branch: refs/heads/camel-2.12.x Commit: 0fc72e85a8a539803e638edefe7d3f0bdd93246f Parents: 4969138 Author: Claus Ibsen <davscl...@apache.org> Authored: Mon Oct 14 11:20:55 2013 +0200 Committer: Claus Ibsen <davscl...@apache.org> Committed: Mon Oct 14 11:22:10 2013 +0200 ---------------------------------------------------------------------- .../apache/camel/component/jms/TwoConsumerOnSameQueueTest.java | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/0fc72e85/components/camel-jms/src/test/java/org/apache/camel/component/jms/TwoConsumerOnSameQueueTest.java ---------------------------------------------------------------------- diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/TwoConsumerOnSameQueueTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/TwoConsumerOnSameQueueTest.java index 55f73db..ecc7ebe 100644 --- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/TwoConsumerOnSameQueueTest.java +++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/TwoConsumerOnSameQueueTest.java @@ -18,11 +18,9 @@ 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; -import org.junit.Ignore; import org.junit.Test; import static org.apache.camel.component.jms.JmsComponent.jmsComponentAutoAcknowledge; @@ -94,7 +92,7 @@ public class TwoConsumerOnSameQueueTest extends CamelTestSupport { protected CamelContext createCamelContext() throws Exception { CamelContext camelContext = super.createCamelContext(); - ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("vm://localhost?broker.persistent=false"); //CamelJmsTestHelper.createConnectionFactory(); + ConnectionFactory connectionFactory = CamelJmsTestHelper.createConnectionFactory(); camelContext.addComponent("activemq", jmsComponentAutoAcknowledge(connectionFactory)); return camelContext;
