Ensure the proper versions of dependencies for Qpid JMS are brought in
for the test.
(cherry picked from commit c239bf01a9)
This commit is contained in:
Timothy Bish 2016-11-01 15:18:21 -04:00
parent fc3206864d
commit 0c280fed60
3 changed files with 17 additions and 28 deletions

View File

@ -1,4 +1,4 @@
/** /*
* Licensed to the Apache Software Foundation (ASF) under one or more * Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed with * contributor license agreements. See the NOTICE file distributed with
* this work for additional information regarding copyright ownership. * this work for additional information regarding copyright ownership.
@ -23,12 +23,10 @@ import java.util.concurrent.Callable;
import javax.jms.Connection; import javax.jms.Connection;
import org.apache.qpid.jms.JmsConnectionFactory; import org.apache.qpid.jms.JmsConnectionFactory;
import org.junit.Before;
import org.junit.Ignore; import org.junit.Ignore;
import org.junit.Test; import org.junit.Test;
import org.junit.runner.RunWith; import org.junit.runner.RunWith;
import org.ops4j.pax.exam.Configuration; import org.ops4j.pax.exam.Configuration;
import org.ops4j.pax.exam.CoreOptions;
import org.ops4j.pax.exam.Option; import org.ops4j.pax.exam.Option;
import org.ops4j.pax.exam.junit.PaxExam; import org.ops4j.pax.exam.junit.PaxExam;
@ -38,44 +36,23 @@ public class ActiveMQAMQPBrokerFeatureTest extends ActiveMQBrokerFeatureTest {
@Configuration @Configuration
public static Option[] configure() { public static Option[] configure() {
Option[] configure = configure("activemq"); Option[] configure = configure("activemq", "activemq-amqp-client");
Option[] configuredOptions = configureBrokerStart(configure); Option[] configuredOptions = configureBrokerStart(configure);
return configuredOptions; 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 @Override
protected Connection getConnection() throws Throwable { protected Connection getConnection() throws Throwable {
setUpBundle();
withinReason(new Callable<Boolean>() { withinReason(new Callable<Boolean>() {
@Override @Override
public Boolean call() throws Exception { 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; return true;
} }
}); });
String amqpURI = "amqp://localhost:" + AMQP_PORT; String amqpURI = "amqp://localhost:" + AMQP_PORT;
JmsConnectionFactory factory = new JmsConnectionFactory(amqpURI); JmsConnectionFactory factory = new JmsConnectionFactory(amqpURI);

View File

@ -20,7 +20,7 @@
<features name="activemq-${project.version}"> <features name="activemq-${project.version}">
<repository>mvn:org.apache.activemq/activemq-karaf/${project.version}/xml/features-core</repository> <repository>mvn:org.apache.activemq/activemq-karaf/${project.version}/xml/features-core</repository>
<!-- Starts the broker with default configuration --> <!-- Starts the broker with default configuration -->
<feature name="activemq-broker-noweb" description="Full ActiveMQ broker with default configuration" version="${project.version}" resolver="(obr)" start-level="50"> <feature name="activemq-broker-noweb" description="Full ActiveMQ broker with default configuration" version="${project.version}" resolver="(obr)" start-level="50">
@ -59,5 +59,15 @@
<bundle>mvn:org.apache.activemq/activemq-blueprint/${project.version}</bundle> <bundle>mvn:org.apache.activemq/activemq-blueprint/${project.version}</bundle>
</feature> </feature>
</features> <feature name="activemq-amqp-client" version="${pom.version}" description="ActiveMQ AMQP protocol client libraries">
<bundle>mvn:io.netty/netty-common/${qpid-jms-netty-version}</bundle>
<bundle>mvn:io.netty/netty-transport/${qpid-jms-netty-version}</bundle>
<bundle>mvn:io.netty/netty-buffer/${qpid-jms-netty-version}</bundle>
<bundle>mvn:io.netty/netty-codec/${qpid-jms-netty-version}</bundle>
<bundle>mvn:io.netty/netty-codec-http/${qpid-jms-netty-version}</bundle>
<bundle>mvn:io.netty/netty-handler/${netty-all-version}</bundle>
<bundle>mvn:org.apache.qpid/proton-j/${qpid-jms-proton-version}</bundle>
<bundle>mvn:org.apache.qpid/qpid-jms-client/${qpid-jms-version}</bundle>
</feature>
</features>

View File

@ -103,6 +103,8 @@
<zookeeper-version>3.4.6</zookeeper-version> <zookeeper-version>3.4.6</zookeeper-version>
<qpid-proton-version>0.15.0</qpid-proton-version> <qpid-proton-version>0.15.0</qpid-proton-version>
<qpid-jms-version>0.11.1</qpid-jms-version> <qpid-jms-version>0.11.1</qpid-jms-version>
<qpid-jms-netty-version>4.0.41.Final</qpid-jms-netty-version>
<qpid-jms-proton-version>0.14.0</qpid-jms-proton-version>
<netty-all-version>4.0.41.Final</netty-all-version> <netty-all-version>4.0.41.Final</netty-all-version>
<regexp-version>1.3</regexp-version> <regexp-version>1.3</regexp-version>
<rome-version>1.0</rome-version> <rome-version>1.0</rome-version>