diff --git a/activemq-karaf-itest/src/test/java/org/apache/activemq/karaf/itest/ActiveMQAMQPBrokerFeatureTest.java b/activemq-karaf-itest/src/test/java/org/apache/activemq/karaf/itest/ActiveMQAMQPBrokerFeatureTest.java index 88c1d8589a..5c6c85df9b 100644 --- a/activemq-karaf-itest/src/test/java/org/apache/activemq/karaf/itest/ActiveMQAMQPBrokerFeatureTest.java +++ b/activemq-karaf-itest/src/test/java/org/apache/activemq/karaf/itest/ActiveMQAMQPBrokerFeatureTest.java @@ -1,4 +1,4 @@ -/** +/* * Licensed to the Apache Software Foundation (ASF) under one or more * contributor license agreements. See the NOTICE file distributed with * this work for additional information regarding copyright ownership. @@ -23,12 +23,10 @@ import java.util.concurrent.Callable; import javax.jms.Connection; import org.apache.qpid.jms.JmsConnectionFactory; -import org.junit.Before; import org.junit.Ignore; import org.junit.Test; import org.junit.runner.RunWith; import org.ops4j.pax.exam.Configuration; -import org.ops4j.pax.exam.CoreOptions; import org.ops4j.pax.exam.Option; import org.ops4j.pax.exam.junit.PaxExam; @@ -38,44 +36,23 @@ public class ActiveMQAMQPBrokerFeatureTest extends ActiveMQBrokerFeatureTest { @Configuration public static Option[] configure() { - Option[] configure = configure("activemq"); + Option[] configure = configure("activemq", "activemq-amqp-client"); Option[] configuredOptions = configureBrokerStart(configure); return configuredOptions; } - - - @Before - public void setUpBundle() { - - installWrappedBundle(CoreOptions.wrappedBundle(CoreOptions.mavenBundle( - "io.netty", "netty-all").version( - getArtifactVersion("io.netty", "netty-all")).getURL().toString() - + "$Bundle-SymbolicName=qpid-jms-client")); - installWrappedBundle(CoreOptions.wrappedBundle(CoreOptions.mavenBundle( - "org.apache.qpid", "proton-j").version( - getArtifactVersion("org.apache.qpid", "proton-j")).getURL())); - installWrappedBundle(CoreOptions.wrappedBundle(CoreOptions.mavenBundle( - "org.apache.qpid", "qpid-jms-client").version( - getArtifactVersion("org.apache.qpid", "qpid-jms-client")).getURL())); - } - - @Override protected Connection getConnection() throws Throwable { - setUpBundle(); - withinReason(new Callable() { @Override public Boolean call() throws Exception { - assertTrue("qpid jms client bundle installed", verifyBundleInstalled("qpid-jms-client")); + assertTrue("qpid jms client bundle installed", verifyBundleInstalled("org.apache.qpid.jms.client")); return true; } }); - String amqpURI = "amqp://localhost:" + AMQP_PORT; JmsConnectionFactory factory = new JmsConnectionFactory(amqpURI); diff --git a/activemq-karaf/src/main/resources/features.xml b/activemq-karaf/src/main/resources/features.xml index 07657706bb..6b1e10bffa 100644 --- a/activemq-karaf/src/main/resources/features.xml +++ b/activemq-karaf/src/main/resources/features.xml @@ -20,7 +20,7 @@ - mvn:org.apache.activemq/activemq-karaf/${project.version}/xml/features-core + mvn:org.apache.activemq/activemq-karaf/${project.version}/xml/features-core @@ -59,5 +59,15 @@ mvn:org.apache.activemq/activemq-blueprint/${project.version} - + + mvn:io.netty/netty-common/${qpid-jms-netty-version} + mvn:io.netty/netty-transport/${qpid-jms-netty-version} + mvn:io.netty/netty-buffer/${qpid-jms-netty-version} + mvn:io.netty/netty-codec/${qpid-jms-netty-version} + mvn:io.netty/netty-codec-http/${qpid-jms-netty-version} + mvn:io.netty/netty-handler/${netty-all-version} + mvn:org.apache.qpid/proton-j/${qpid-jms-proton-version} + mvn:org.apache.qpid/qpid-jms-client/${qpid-jms-version} + + diff --git a/pom.xml b/pom.xml index 10dabc9a10..f43bf47178 100755 --- a/pom.xml +++ b/pom.xml @@ -104,6 +104,8 @@ 3.4.6 0.15.0 0.11.1 + 4.0.41.Final + 0.14.0 4.0.41.Final 1.3 1.0