Commit 2861c765 authored by Phillip Webb's avatar Phillip Webb

Polish

parent e992d389
...@@ -16,6 +16,8 @@ ...@@ -16,6 +16,8 @@
package org.springframework.boot.autoconfigure.jms.activemq; package org.springframework.boot.autoconfigure.jms.activemq;
import java.lang.reflect.InvocationTargetException;
import org.apache.activemq.ActiveMQConnectionFactory; import org.apache.activemq.ActiveMQConnectionFactory;
import org.springframework.boot.autoconfigure.jms.activemq.ActiveMQProperties.Packages; import org.springframework.boot.autoconfigure.jms.activemq.ActiveMQProperties.Packages;
...@@ -56,27 +58,28 @@ class ActiveMQConnectionFactoryFactory { ...@@ -56,27 +58,28 @@ class ActiveMQConnectionFactoryFactory {
private <T extends ActiveMQConnectionFactory> T doCreateConnectionFactory( private <T extends ActiveMQConnectionFactory> T doCreateConnectionFactory(
Class<T> factoryClass) throws Exception { Class<T> factoryClass) throws Exception {
T factory = createConnectionFactoryInstance(factoryClass);
Packages packages = this.properties.getPackages();
if (packages.getTrustAll() != null) {
factory.setTrustAllPackages(packages.getTrustAll());
}
if (!packages.getTrusted().isEmpty()) {
factory.setTrustedPackages(packages.getTrusted());
}
return factory;
}
private <T extends ActiveMQConnectionFactory> T createConnectionFactoryInstance(
Class<T> factoryClass) throws InstantiationException, IllegalAccessException,
InvocationTargetException, NoSuchMethodException {
String brokerUrl = determineBrokerUrl(); String brokerUrl = determineBrokerUrl();
String user = this.properties.getUser(); String user = this.properties.getUser();
String password = this.properties.getPassword(); String password = this.properties.getPassword();
T activeMqConnectionFactory;
if (StringUtils.hasLength(user) && StringUtils.hasLength(password)) { if (StringUtils.hasLength(user) && StringUtils.hasLength(password)) {
activeMqConnectionFactory = factoryClass return factoryClass.getConstructor(String.class, String.class, String.class)
.getConstructor(String.class, String.class, String.class)
.newInstance(user, password, brokerUrl); .newInstance(user, password, brokerUrl);
} }
else { return factoryClass.getConstructor(String.class).newInstance(brokerUrl);
activeMqConnectionFactory = factoryClass.getConstructor(String.class)
.newInstance(brokerUrl);
}
Packages packages = this.properties.getPackages();
if (packages.getTrustAll() != null) {
activeMqConnectionFactory.setTrustAllPackages(packages.getTrustAll());
}
if (!packages.getTrusted().isEmpty()) {
activeMqConnectionFactory.setTrustedPackages(packages.getTrusted());
}
return activeMqConnectionFactory;
} }
String determineBrokerUrl() { String determineBrokerUrl() {
......
...@@ -732,6 +732,7 @@ public class TomcatEmbeddedServletContainerFactory ...@@ -732,6 +732,7 @@ public class TomcatEmbeddedServletContainerFactory
*/ */
private static class StoreMergedWebXmlListener implements LifecycleListener { private static class StoreMergedWebXmlListener implements LifecycleListener {
@SuppressWarnings("deprecation")
private final String MERGED_WEB_XML = org.apache.tomcat.util.scan.Constants.MERGED_WEB_XML; private final String MERGED_WEB_XML = org.apache.tomcat.util.scan.Constants.MERGED_WEB_XML;
@Override @Override
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment