Remove support for HornetQ following its deprecation in 1.4
See gh-6971pull/7075/head
Andy Wilkinson
8 years ago
parent
0232e3b16c
commit
464915d2cc
@ -1,58 +0,0 @@
|
|||||||
/*
|
|
||||||
* Copyright 2012-2016 the original author or authors.
|
|
||||||
*
|
|
||||||
* Licensed under the Apache License, Version 2.0 (the "License");
|
|
||||||
* you may not use this file except in compliance with the License.
|
|
||||||
* You may obtain a copy of the License at
|
|
||||||
*
|
|
||||||
* http://www.apache.org/licenses/LICENSE-2.0
|
|
||||||
*
|
|
||||||
* Unless required by applicable law or agreed to in writing, software
|
|
||||||
* distributed under the License is distributed on an "AS IS" BASIS,
|
|
||||||
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
||||||
* See the License for the specific language governing permissions and
|
|
||||||
* limitations under the License.
|
|
||||||
*/
|
|
||||||
|
|
||||||
package org.springframework.boot.autoconfigure.jms.hornetq;
|
|
||||||
|
|
||||||
import javax.jms.ConnectionFactory;
|
|
||||||
|
|
||||||
import org.hornetq.api.jms.HornetQJMSClient;
|
|
||||||
|
|
||||||
import org.springframework.boot.autoconfigure.AutoConfigureAfter;
|
|
||||||
import org.springframework.boot.autoconfigure.AutoConfigureBefore;
|
|
||||||
import org.springframework.boot.autoconfigure.EnableAutoConfiguration;
|
|
||||||
import org.springframework.boot.autoconfigure.condition.ConditionalOnClass;
|
|
||||||
import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
|
|
||||||
import org.springframework.boot.autoconfigure.jms.JmsAutoConfiguration;
|
|
||||||
import org.springframework.boot.autoconfigure.jms.JndiConnectionFactoryAutoConfiguration;
|
|
||||||
import org.springframework.boot.context.properties.EnableConfigurationProperties;
|
|
||||||
import org.springframework.context.annotation.Configuration;
|
|
||||||
import org.springframework.context.annotation.Import;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* {@link EnableAutoConfiguration Auto-configuration} to integrate with an HornetQ broker.
|
|
||||||
* If the necessary classes are present, embed the broker in the application by default.
|
|
||||||
* Otherwise, connect to a broker available on the local machine with the default
|
|
||||||
* settings.
|
|
||||||
*
|
|
||||||
* @author Stephane Nicoll
|
|
||||||
* @author Phillip Webb
|
|
||||||
* @since 1.1.0
|
|
||||||
* @see HornetQProperties
|
|
||||||
* @deprecated as of 1.4 in favor of the Artemis support
|
|
||||||
*/
|
|
||||||
@Configuration
|
|
||||||
@AutoConfigureBefore(JmsAutoConfiguration.class)
|
|
||||||
@AutoConfigureAfter({ JndiConnectionFactoryAutoConfiguration.class })
|
|
||||||
@ConditionalOnClass({ ConnectionFactory.class, HornetQJMSClient.class })
|
|
||||||
@ConditionalOnMissingBean(ConnectionFactory.class)
|
|
||||||
@EnableConfigurationProperties(HornetQProperties.class)
|
|
||||||
@Import({ HornetQEmbeddedServerConfiguration.class,
|
|
||||||
HornetQXAConnectionFactoryConfiguration.class,
|
|
||||||
HornetQConnectionFactoryConfiguration.class })
|
|
||||||
@Deprecated
|
|
||||||
public class HornetQAutoConfiguration {
|
|
||||||
|
|
||||||
}
|
|
||||||
@ -1,41 +0,0 @@
|
|||||||
/*
|
|
||||||
* Copyright 2012-2016 the original author or authors.
|
|
||||||
*
|
|
||||||
* Licensed under the Apache License, Version 2.0 (the "License");
|
|
||||||
* you may not use this file except in compliance with the License.
|
|
||||||
* You may obtain a copy of the License at
|
|
||||||
*
|
|
||||||
* http://www.apache.org/licenses/LICENSE-2.0
|
|
||||||
*
|
|
||||||
* Unless required by applicable law or agreed to in writing, software
|
|
||||||
* distributed under the License is distributed on an "AS IS" BASIS,
|
|
||||||
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
||||||
* See the License for the specific language governing permissions and
|
|
||||||
* limitations under the License.
|
|
||||||
*/
|
|
||||||
|
|
||||||
package org.springframework.boot.autoconfigure.jms.hornetq;
|
|
||||||
|
|
||||||
import org.hornetq.core.config.Configuration;
|
|
||||||
import org.hornetq.jms.server.embedded.EmbeddedJMS;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Callback interface that can be implemented by beans wishing to customize the HornetQ
|
|
||||||
* JMS server {@link Configuration} before it is used by an auto-configured
|
|
||||||
* {@link EmbeddedJMS} instance.
|
|
||||||
*
|
|
||||||
* @author Phillip Webb
|
|
||||||
* @since 1.1.0
|
|
||||||
* @see HornetQAutoConfiguration
|
|
||||||
* @deprecated as of 1.4 in favor of the Artemis support
|
|
||||||
*/
|
|
||||||
@Deprecated
|
|
||||||
public interface HornetQConfigurationCustomizer {
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Customize the configuration.
|
|
||||||
* @param configuration the configuration to customize
|
|
||||||
*/
|
|
||||||
void customize(Configuration configuration);
|
|
||||||
|
|
||||||
}
|
|
||||||
@ -1,47 +0,0 @@
|
|||||||
/*
|
|
||||||
* Copyright 2012-2016 the original author or authors.
|
|
||||||
*
|
|
||||||
* Licensed under the Apache License, Version 2.0 (the "License");
|
|
||||||
* you may not use this file except in compliance with the License.
|
|
||||||
* You may obtain a copy of the License at
|
|
||||||
*
|
|
||||||
* http://www.apache.org/licenses/LICENSE-2.0
|
|
||||||
*
|
|
||||||
* Unless required by applicable law or agreed to in writing, software
|
|
||||||
* distributed under the License is distributed on an "AS IS" BASIS,
|
|
||||||
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
||||||
* See the License for the specific language governing permissions and
|
|
||||||
* limitations under the License.
|
|
||||||
*/
|
|
||||||
|
|
||||||
package org.springframework.boot.autoconfigure.jms.hornetq;
|
|
||||||
|
|
||||||
import javax.jms.ConnectionFactory;
|
|
||||||
|
|
||||||
import org.hornetq.jms.client.HornetQConnectionFactory;
|
|
||||||
|
|
||||||
import org.springframework.beans.factory.ListableBeanFactory;
|
|
||||||
import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
|
|
||||||
import org.springframework.context.annotation.Bean;
|
|
||||||
import org.springframework.context.annotation.Configuration;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Configuration for HornetQ {@link ConnectionFactory}.
|
|
||||||
*
|
|
||||||
* @author Phillip Webb
|
|
||||||
* @since 1.2.0
|
|
||||||
* @deprecated as of 1.4 in favor of the Artemis support
|
|
||||||
*/
|
|
||||||
@Configuration
|
|
||||||
@ConditionalOnMissingBean(ConnectionFactory.class)
|
|
||||||
@Deprecated
|
|
||||||
class HornetQConnectionFactoryConfiguration {
|
|
||||||
|
|
||||||
@Bean
|
|
||||||
public HornetQConnectionFactory jmsConnectionFactory(ListableBeanFactory beanFactory,
|
|
||||||
HornetQProperties properties) {
|
|
||||||
return new HornetQConnectionFactoryFactory(beanFactory, properties)
|
|
||||||
.createConnectionFactory(SpringBootHornetQConnectionFactory.class);
|
|
||||||
}
|
|
||||||
|
|
||||||
}
|
|
||||||
@ -1,142 +0,0 @@
|
|||||||
/*
|
|
||||||
* Copyright 2012-2016 the original author or authors.
|
|
||||||
*
|
|
||||||
* Licensed under the Apache License, Version 2.0 (the "License");
|
|
||||||
* you may not use this file except in compliance with the License.
|
|
||||||
* You may obtain a copy of the License at
|
|
||||||
*
|
|
||||||
* http://www.apache.org/licenses/LICENSE-2.0
|
|
||||||
*
|
|
||||||
* Unless required by applicable law or agreed to in writing, software
|
|
||||||
* distributed under the License is distributed on an "AS IS" BASIS,
|
|
||||||
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
||||||
* See the License for the specific language governing permissions and
|
|
||||||
* limitations under the License.
|
|
||||||
*/
|
|
||||||
|
|
||||||
package org.springframework.boot.autoconfigure.jms.hornetq;
|
|
||||||
|
|
||||||
import java.lang.reflect.Constructor;
|
|
||||||
import java.util.HashMap;
|
|
||||||
import java.util.Map;
|
|
||||||
|
|
||||||
import org.hornetq.api.core.TransportConfiguration;
|
|
||||||
import org.hornetq.api.core.client.HornetQClient;
|
|
||||||
import org.hornetq.api.core.client.ServerLocator;
|
|
||||||
import org.hornetq.core.remoting.impl.invm.InVMConnectorFactory;
|
|
||||||
import org.hornetq.core.remoting.impl.netty.NettyConnectorFactory;
|
|
||||||
import org.hornetq.core.remoting.impl.netty.TransportConstants;
|
|
||||||
import org.hornetq.jms.client.HornetQConnectionFactory;
|
|
||||||
|
|
||||||
import org.springframework.beans.BeanUtils;
|
|
||||||
import org.springframework.beans.factory.ListableBeanFactory;
|
|
||||||
import org.springframework.util.Assert;
|
|
||||||
import org.springframework.util.ClassUtils;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Factory to create a {@link HornetQConnectionFactory} instance from properties defined
|
|
||||||
* in {@link HornetQProperties}.
|
|
||||||
*
|
|
||||||
* @author Phillip Webb
|
|
||||||
* @author Stephane Nicoll
|
|
||||||
* @since 1.2.0
|
|
||||||
* @deprecated as of 1.4 in favor of the Artemis support
|
|
||||||
*/
|
|
||||||
@Deprecated
|
|
||||||
class HornetQConnectionFactoryFactory {
|
|
||||||
|
|
||||||
static final String EMBEDDED_JMS_CLASS = "org.hornetq.jms.server.embedded.EmbeddedJMS";
|
|
||||||
|
|
||||||
private final HornetQProperties properties;
|
|
||||||
|
|
||||||
private final ListableBeanFactory beanFactory;
|
|
||||||
|
|
||||||
HornetQConnectionFactoryFactory(ListableBeanFactory beanFactory,
|
|
||||||
HornetQProperties properties) {
|
|
||||||
Assert.notNull(beanFactory, "BeanFactory must not be null");
|
|
||||||
Assert.notNull(properties, "Properties must not be null");
|
|
||||||
this.beanFactory = beanFactory;
|
|
||||||
this.properties = properties;
|
|
||||||
}
|
|
||||||
|
|
||||||
public <T extends HornetQConnectionFactory> T createConnectionFactory(
|
|
||||||
Class<T> factoryClass) {
|
|
||||||
try {
|
|
||||||
startEmbeddedJms();
|
|
||||||
return doCreateConnectionFactory(factoryClass);
|
|
||||||
}
|
|
||||||
catch (Exception ex) {
|
|
||||||
throw new IllegalStateException(
|
|
||||||
"Unable to create " + "HornetQConnectionFactory", ex);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
private void startEmbeddedJms() {
|
|
||||||
if (ClassUtils.isPresent(EMBEDDED_JMS_CLASS, null)) {
|
|
||||||
try {
|
|
||||||
this.beanFactory.getBeansOfType(Class.forName(EMBEDDED_JMS_CLASS));
|
|
||||||
}
|
|
||||||
catch (Exception ex) {
|
|
||||||
// Ignore
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
private <T extends HornetQConnectionFactory> T doCreateConnectionFactory(
|
|
||||||
Class<T> factoryClass) throws Exception {
|
|
||||||
HornetQMode mode = this.properties.getMode();
|
|
||||||
if (mode == null) {
|
|
||||||
mode = deduceMode();
|
|
||||||
}
|
|
||||||
if (mode == HornetQMode.EMBEDDED) {
|
|
||||||
return createEmbeddedConnectionFactory(factoryClass);
|
|
||||||
}
|
|
||||||
return createNativeConnectionFactory(factoryClass);
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Deduce the {@link HornetQMode} to use if none has been set.
|
|
||||||
* @return the mode
|
|
||||||
*/
|
|
||||||
private HornetQMode deduceMode() {
|
|
||||||
if (this.properties.getEmbedded().isEnabled()
|
|
||||||
&& ClassUtils.isPresent(EMBEDDED_JMS_CLASS, null)) {
|
|
||||||
return HornetQMode.EMBEDDED;
|
|
||||||
}
|
|
||||||
return HornetQMode.NATIVE;
|
|
||||||
}
|
|
||||||
|
|
||||||
private <T extends HornetQConnectionFactory> T createEmbeddedConnectionFactory(
|
|
||||||
Class<T> factoryClass) throws Exception {
|
|
||||||
try {
|
|
||||||
TransportConfiguration transportConfiguration = new TransportConfiguration(
|
|
||||||
InVMConnectorFactory.class.getName(),
|
|
||||||
this.properties.getEmbedded().generateTransportParameters());
|
|
||||||
ServerLocator serviceLocator = HornetQClient
|
|
||||||
.createServerLocatorWithoutHA(transportConfiguration);
|
|
||||||
Constructor<T> constructor = factoryClass
|
|
||||||
.getDeclaredConstructor(HornetQProperties.class, ServerLocator.class);
|
|
||||||
return BeanUtils.instantiateClass(constructor, this.properties,
|
|
||||||
serviceLocator);
|
|
||||||
}
|
|
||||||
catch (NoClassDefFoundError ex) {
|
|
||||||
throw new IllegalStateException("Unable to create InVM "
|
|
||||||
+ "HornetQ connection, ensure that hornet-jms-server.jar "
|
|
||||||
+ "is in the classpath", ex);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
private <T extends HornetQConnectionFactory> T createNativeConnectionFactory(
|
|
||||||
Class<T> factoryClass) throws Exception {
|
|
||||||
Map<String, Object> params = new HashMap<String, Object>();
|
|
||||||
params.put(TransportConstants.HOST_PROP_NAME, this.properties.getHost());
|
|
||||||
params.put(TransportConstants.PORT_PROP_NAME, this.properties.getPort());
|
|
||||||
TransportConfiguration transportConfiguration = new TransportConfiguration(
|
|
||||||
NettyConnectorFactory.class.getName(), params);
|
|
||||||
Constructor<T> constructor = factoryClass.getDeclaredConstructor(
|
|
||||||
HornetQProperties.class, boolean.class, TransportConfiguration[].class);
|
|
||||||
return BeanUtils.instantiateClass(constructor, this.properties, false,
|
|
||||||
new TransportConfiguration[] { transportConfiguration });
|
|
||||||
}
|
|
||||||
|
|
||||||
}
|
|
||||||
@ -1,90 +0,0 @@
|
|||||||
/*
|
|
||||||
* Copyright 2012-2016 the original author or authors.
|
|
||||||
*
|
|
||||||
* Licensed under the Apache License, Version 2.0 (the "License");
|
|
||||||
* you may not use this file except in compliance with the License.
|
|
||||||
* You may obtain a copy of the License at
|
|
||||||
*
|
|
||||||
* http://www.apache.org/licenses/LICENSE-2.0
|
|
||||||
*
|
|
||||||
* Unless required by applicable law or agreed to in writing, software
|
|
||||||
* distributed under the License is distributed on an "AS IS" BASIS,
|
|
||||||
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
||||||
* See the License for the specific language governing permissions and
|
|
||||||
* limitations under the License.
|
|
||||||
*/
|
|
||||||
|
|
||||||
package org.springframework.boot.autoconfigure.jms.hornetq;
|
|
||||||
|
|
||||||
import java.io.File;
|
|
||||||
|
|
||||||
import org.apache.commons.logging.Log;
|
|
||||||
import org.apache.commons.logging.LogFactory;
|
|
||||||
import org.hornetq.api.core.TransportConfiguration;
|
|
||||||
import org.hornetq.core.config.Configuration;
|
|
||||||
import org.hornetq.core.config.impl.ConfigurationImpl;
|
|
||||||
import org.hornetq.core.remoting.impl.invm.InVMAcceptorFactory;
|
|
||||||
import org.hornetq.core.server.JournalType;
|
|
||||||
|
|
||||||
import org.springframework.boot.autoconfigure.jms.hornetq.HornetQProperties.Embedded;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Factory class to create a HornetQ {@link Configuration} from {@link HornetQProperties}.
|
|
||||||
*
|
|
||||||
* @author Stephane Nicoll
|
|
||||||
* @author Phillip Webb
|
|
||||||
* @since 1.1.0
|
|
||||||
* @deprecated as of 1.4 in favor of the Artemis support
|
|
||||||
*/
|
|
||||||
@Deprecated
|
|
||||||
class HornetQEmbeddedConfigurationFactory {
|
|
||||||
|
|
||||||
private static final Log logger = LogFactory
|
|
||||||
.getLog(HornetQEmbeddedConfigurationFactory.class);
|
|
||||||
|
|
||||||
private final Embedded properties;
|
|
||||||
|
|
||||||
HornetQEmbeddedConfigurationFactory(HornetQProperties properties) {
|
|
||||||
this.properties = properties.getEmbedded();
|
|
||||||
}
|
|
||||||
|
|
||||||
public Configuration createConfiguration() {
|
|
||||||
ConfigurationImpl configuration = new ConfigurationImpl();
|
|
||||||
configuration.setSecurityEnabled(false);
|
|
||||||
configuration.setPersistenceEnabled(this.properties.isPersistent());
|
|
||||||
|
|
||||||
String dataDir = getDataDir();
|
|
||||||
|
|
||||||
// HORNETQ-1302
|
|
||||||
configuration.setJournalDirectory(dataDir + "/journal");
|
|
||||||
|
|
||||||
if (this.properties.isPersistent()) {
|
|
||||||
configuration.setJournalType(JournalType.NIO);
|
|
||||||
configuration.setLargeMessagesDirectory(dataDir + "/largemessages");
|
|
||||||
configuration.setBindingsDirectory(dataDir + "/bindings");
|
|
||||||
configuration.setPagingDirectory(dataDir + "/paging");
|
|
||||||
}
|
|
||||||
|
|
||||||
TransportConfiguration transportConfiguration = new TransportConfiguration(
|
|
||||||
InVMAcceptorFactory.class.getName(),
|
|
||||||
this.properties.generateTransportParameters());
|
|
||||||
configuration.getAcceptorConfigurations().add(transportConfiguration);
|
|
||||||
|
|
||||||
// HORNETQ-1143
|
|
||||||
if (this.properties.isDefaultClusterPassword()) {
|
|
||||||
logger.debug("Using default HornetQ cluster password: "
|
|
||||||
+ this.properties.getClusterPassword());
|
|
||||||
}
|
|
||||||
|
|
||||||
configuration.setClusterPassword(this.properties.getClusterPassword());
|
|
||||||
return configuration;
|
|
||||||
}
|
|
||||||
|
|
||||||
private String getDataDir() {
|
|
||||||
if (this.properties.getDataDirectory() != null) {
|
|
||||||
return this.properties.getDataDirectory();
|
|
||||||
}
|
|
||||||
String tempDirectory = System.getProperty("java.io.tmpdir");
|
|
||||||
return new File(tempDirectory, "hornetq-data").getAbsolutePath();
|
|
||||||
}
|
|
||||||
}
|
|
||||||
@ -1,130 +0,0 @@
|
|||||||
/*
|
|
||||||
* Copyright 2012-2016 the original author or authors.
|
|
||||||
*
|
|
||||||
* Licensed under the Apache License, Version 2.0 (the "License");
|
|
||||||
* you may not use this file except in compliance with the License.
|
|
||||||
* You may obtain a copy of the License at
|
|
||||||
*
|
|
||||||
* http://www.apache.org/licenses/LICENSE-2.0
|
|
||||||
*
|
|
||||||
* Unless required by applicable law or agreed to in writing, software
|
|
||||||
* distributed under the License is distributed on an "AS IS" BASIS,
|
|
||||||
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
||||||
* See the License for the specific language governing permissions and
|
|
||||||
* limitations under the License.
|
|
||||||
*/
|
|
||||||
|
|
||||||
package org.springframework.boot.autoconfigure.jms.hornetq;
|
|
||||||
|
|
||||||
import java.util.Collection;
|
|
||||||
import java.util.List;
|
|
||||||
|
|
||||||
import org.hornetq.jms.server.config.JMSConfiguration;
|
|
||||||
import org.hornetq.jms.server.config.JMSQueueConfiguration;
|
|
||||||
import org.hornetq.jms.server.config.TopicConfiguration;
|
|
||||||
import org.hornetq.jms.server.config.impl.JMSConfigurationImpl;
|
|
||||||
import org.hornetq.jms.server.config.impl.JMSQueueConfigurationImpl;
|
|
||||||
import org.hornetq.jms.server.config.impl.TopicConfigurationImpl;
|
|
||||||
import org.hornetq.jms.server.embedded.EmbeddedJMS;
|
|
||||||
|
|
||||||
import org.springframework.beans.factory.ObjectProvider;
|
|
||||||
import org.springframework.boot.autoconfigure.condition.ConditionalOnClass;
|
|
||||||
import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
|
|
||||||
import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
|
|
||||||
import org.springframework.context.annotation.Bean;
|
|
||||||
import org.springframework.context.annotation.Configuration;
|
|
||||||
import org.springframework.core.annotation.AnnotationAwareOrderComparator;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Configuration used to create the embedded HornetQ server.
|
|
||||||
*
|
|
||||||
* @author Phillip Webb
|
|
||||||
* @author Stephane Nicoll
|
|
||||||
* @since 1.2.0
|
|
||||||
* @deprecated as of 1.4 in favor of the Artemis support
|
|
||||||
*/
|
|
||||||
@Configuration
|
|
||||||
@ConditionalOnClass(name = HornetQConnectionFactoryFactory.EMBEDDED_JMS_CLASS)
|
|
||||||
@ConditionalOnProperty(prefix = "spring.hornetq.embedded", name = "enabled", havingValue = "true", matchIfMissing = true)
|
|
||||||
@Deprecated
|
|
||||||
class HornetQEmbeddedServerConfiguration {
|
|
||||||
|
|
||||||
private final HornetQProperties properties;
|
|
||||||
|
|
||||||
private final List<HornetQConfigurationCustomizer> configurationCustomizers;
|
|
||||||
|
|
||||||
private final List<JMSQueueConfiguration> queuesConfiguration;
|
|
||||||
|
|
||||||
private final List<TopicConfiguration> topicsConfiguration;
|
|
||||||
|
|
||||||
HornetQEmbeddedServerConfiguration(HornetQProperties properties,
|
|
||||||
ObjectProvider<List<HornetQConfigurationCustomizer>> configurationCustomizersProvider,
|
|
||||||
ObjectProvider<List<JMSQueueConfiguration>> queuesConfigurationProvider,
|
|
||||||
ObjectProvider<List<TopicConfiguration>> topicsConfigurationProvider) {
|
|
||||||
this.properties = properties;
|
|
||||||
this.configurationCustomizers = configurationCustomizersProvider.getIfAvailable();
|
|
||||||
this.queuesConfiguration = queuesConfigurationProvider.getIfAvailable();
|
|
||||||
this.topicsConfiguration = topicsConfigurationProvider.getIfAvailable();
|
|
||||||
}
|
|
||||||
|
|
||||||
@Bean
|
|
||||||
@ConditionalOnMissingBean
|
|
||||||
public org.hornetq.core.config.Configuration hornetQConfiguration() {
|
|
||||||
return new HornetQEmbeddedConfigurationFactory(this.properties)
|
|
||||||
.createConfiguration();
|
|
||||||
}
|
|
||||||
|
|
||||||
@Bean(initMethod = "start", destroyMethod = "stop")
|
|
||||||
@ConditionalOnMissingBean
|
|
||||||
public EmbeddedJMS hornetQServer(org.hornetq.core.config.Configuration configuration,
|
|
||||||
JMSConfiguration jmsConfiguration) {
|
|
||||||
EmbeddedJMS server = new EmbeddedJMS();
|
|
||||||
customize(configuration);
|
|
||||||
server.setConfiguration(configuration);
|
|
||||||
server.setJmsConfiguration(jmsConfiguration);
|
|
||||||
server.setRegistry(new HornetQNoOpBindingRegistry());
|
|
||||||
return server;
|
|
||||||
}
|
|
||||||
|
|
||||||
private void customize(org.hornetq.core.config.Configuration configuration) {
|
|
||||||
if (this.configurationCustomizers != null) {
|
|
||||||
AnnotationAwareOrderComparator.sort(this.configurationCustomizers);
|
|
||||||
for (HornetQConfigurationCustomizer customizer : this.configurationCustomizers) {
|
|
||||||
customizer.customize(configuration);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
@Bean
|
|
||||||
@ConditionalOnMissingBean
|
|
||||||
public JMSConfiguration hornetQJmsConfiguration() {
|
|
||||||
JMSConfiguration configuration = new JMSConfigurationImpl();
|
|
||||||
addAll(configuration.getQueueConfigurations(), this.queuesConfiguration);
|
|
||||||
addAll(configuration.getTopicConfigurations(), this.topicsConfiguration);
|
|
||||||
addQueues(configuration, this.properties.getEmbedded().getQueues());
|
|
||||||
addTopics(configuration, this.properties.getEmbedded().getTopics());
|
|
||||||
return configuration;
|
|
||||||
}
|
|
||||||
|
|
||||||
private <T> void addAll(List<T> list, Collection<? extends T> items) {
|
|
||||||
if (items != null) {
|
|
||||||
list.addAll(items);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
private void addQueues(JMSConfiguration configuration, String[] queues) {
|
|
||||||
boolean persistent = this.properties.getEmbedded().isPersistent();
|
|
||||||
for (String queue : queues) {
|
|
||||||
configuration.getQueueConfigurations().add(new JMSQueueConfigurationImpl(
|
|
||||||
queue, null, persistent, "/queue/" + queue));
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
private void addTopics(JMSConfiguration configuration, String[] topics) {
|
|
||||||
for (String topic : topics) {
|
|
||||||
configuration.getTopicConfigurations()
|
|
||||||
.add(new TopicConfigurationImpl(topic, "/topic/" + topic));
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
}
|
|
||||||
@ -1,39 +0,0 @@
|
|||||||
/*
|
|
||||||
* Copyright 2012-2016 the original author or authors.
|
|
||||||
*
|
|
||||||
* Licensed under the Apache License, Version 2.0 (the "License");
|
|
||||||
* you may not use this file except in compliance with the License.
|
|
||||||
* You may obtain a copy of the License at
|
|
||||||
*
|
|
||||||
* http://www.apache.org/licenses/LICENSE-2.0
|
|
||||||
*
|
|
||||||
* Unless required by applicable law or agreed to in writing, software
|
|
||||||
* distributed under the License is distributed on an "AS IS" BASIS,
|
|
||||||
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
||||||
* See the License for the specific language governing permissions and
|
|
||||||
* limitations under the License.
|
|
||||||
*/
|
|
||||||
|
|
||||||
package org.springframework.boot.autoconfigure.jms.hornetq;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Define the mode in which HornetQ can operate.
|
|
||||||
*
|
|
||||||
* @author Stephane Nicoll
|
|
||||||
* @since 1.1.0
|
|
||||||
* @deprecated as of 1.4 in favor of the Artemis support
|
|
||||||
*/
|
|
||||||
@Deprecated
|
|
||||||
public enum HornetQMode {
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Connect to a broker using the native HornetQ protocol (i.e. netty).
|
|
||||||
*/
|
|
||||||
NATIVE,
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Embed (i.e. start) the broker in the application.
|
|
||||||
*/
|
|
||||||
EMBEDDED
|
|
||||||
|
|
||||||
}
|
|
||||||
@ -1,66 +0,0 @@
|
|||||||
/*
|
|
||||||
* Copyright 2012-2016 the original author or authors.
|
|
||||||
*
|
|
||||||
* Licensed under the Apache License, Version 2.0 (the "License");
|
|
||||||
* you may not use this file except in compliance with the License.
|
|
||||||
* You may obtain a copy of the License at
|
|
||||||
*
|
|
||||||
* http://www.apache.org/licenses/LICENSE-2.0
|
|
||||||
*
|
|
||||||
* Unless required by applicable law or agreed to in writing, software
|
|
||||||
* distributed under the License is distributed on an "AS IS" BASIS,
|
|
||||||
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
||||||
* See the License for the specific language governing permissions and
|
|
||||||
* limitations under the License.
|
|
||||||
*/
|
|
||||||
|
|
||||||
package org.springframework.boot.autoconfigure.jms.hornetq;
|
|
||||||
|
|
||||||
import org.hornetq.spi.core.naming.BindingRegistry;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* A no-op implementation of the {@link org.hornetq.spi.core.naming.BindingRegistry}.
|
|
||||||
*
|
|
||||||
* @author Stephane Nicoll
|
|
||||||
* @since 1.1.0
|
|
||||||
* @deprecated as of 1.4 in favor of the Artemis support
|
|
||||||
*/
|
|
||||||
@Deprecated
|
|
||||||
public class HornetQNoOpBindingRegistry implements BindingRegistry {
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public Object lookup(String name) {
|
|
||||||
// This callback is used to check if an entry is present in the context before
|
|
||||||
// creating a queue on the fly. This is actually never used to try to fetch a
|
|
||||||
// destination that is unknown.
|
|
||||||
return null;
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public boolean bind(String name, Object obj) {
|
|
||||||
// This callback is used bind a Destination created on the fly by the embedded
|
|
||||||
// broker using the JNDI name that was specified in the configuration. This does
|
|
||||||
// not look very useful since it's used nowhere. It could be interesting to
|
|
||||||
// autowire a destination to use it but the wiring is a bit "asynchronous" so
|
|
||||||
// better not provide that feature at all.
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public void unbind(String name) {
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public void close() {
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public Object getContext() {
|
|
||||||
return this;
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public void setContext(Object ctx) {
|
|
||||||
}
|
|
||||||
|
|
||||||
}
|
|
||||||
@ -1,230 +0,0 @@
|
|||||||
/*
|
|
||||||
* Copyright 2012-2016 the original author or authors.
|
|
||||||
*
|
|
||||||
* Licensed under the Apache License, Version 2.0 (the "License");
|
|
||||||
* you may not use this file except in compliance with the License.
|
|
||||||
* You may obtain a copy of the License at
|
|
||||||
*
|
|
||||||
* http://www.apache.org/licenses/LICENSE-2.0
|
|
||||||
*
|
|
||||||
* Unless required by applicable law or agreed to in writing, software
|
|
||||||
* distributed under the License is distributed on an "AS IS" BASIS,
|
|
||||||
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
||||||
* See the License for the specific language governing permissions and
|
|
||||||
* limitations under the License.
|
|
||||||
*/
|
|
||||||
|
|
||||||
package org.springframework.boot.autoconfigure.jms.hornetq;
|
|
||||||
|
|
||||||
import java.util.HashMap;
|
|
||||||
import java.util.Map;
|
|
||||||
import java.util.UUID;
|
|
||||||
import java.util.concurrent.atomic.AtomicInteger;
|
|
||||||
|
|
||||||
import org.hornetq.core.remoting.impl.invm.TransportConstants;
|
|
||||||
|
|
||||||
import org.springframework.boot.context.properties.ConfigurationProperties;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Configuration properties for HornetQ.
|
|
||||||
*
|
|
||||||
* @author Stephane Nicoll
|
|
||||||
* @since 1.1.0
|
|
||||||
* @deprecated as of 1.4 in favor of the Artemis support
|
|
||||||
*/
|
|
||||||
@ConfigurationProperties(prefix = "spring.hornetq")
|
|
||||||
@Deprecated
|
|
||||||
public class HornetQProperties {
|
|
||||||
|
|
||||||
/**
|
|
||||||
* HornetQ deployment mode, auto-detected by default.
|
|
||||||
*/
|
|
||||||
private HornetQMode mode;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* HornetQ broker host.
|
|
||||||
*/
|
|
||||||
private String host = "localhost";
|
|
||||||
|
|
||||||
/**
|
|
||||||
* HornetQ broker port.
|
|
||||||
*/
|
|
||||||
private int port = 5445;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Login user of the broker.
|
|
||||||
*/
|
|
||||||
private String user;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Login password of the broker.
|
|
||||||
*/
|
|
||||||
private String password;
|
|
||||||
|
|
||||||
private final Embedded embedded = new Embedded();
|
|
||||||
|
|
||||||
public HornetQMode getMode() {
|
|
||||||
return this.mode;
|
|
||||||
}
|
|
||||||
|
|
||||||
public void setMode(HornetQMode mode) {
|
|
||||||
this.mode = mode;
|
|
||||||
}
|
|
||||||
|
|
||||||
public String getHost() {
|
|
||||||
return this.host;
|
|
||||||
}
|
|
||||||
|
|
||||||
public void setHost(String host) {
|
|
||||||
this.host = host;
|
|
||||||
}
|
|
||||||
|
|
||||||
public int getPort() {
|
|
||||||
return this.port;
|
|
||||||
}
|
|
||||||
|
|
||||||
public void setPort(int port) {
|
|
||||||
this.port = port;
|
|
||||||
}
|
|
||||||
|
|
||||||
public String getUser() {
|
|
||||||
return this.user;
|
|
||||||
}
|
|
||||||
|
|
||||||
public void setUser(String user) {
|
|
||||||
this.user = user;
|
|
||||||
}
|
|
||||||
|
|
||||||
public String getPassword() {
|
|
||||||
return this.password;
|
|
||||||
}
|
|
||||||
|
|
||||||
public void setPassword(String password) {
|
|
||||||
this.password = password;
|
|
||||||
}
|
|
||||||
|
|
||||||
public Embedded getEmbedded() {
|
|
||||||
return this.embedded;
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Configuration for an embedded HornetQ server.
|
|
||||||
*/
|
|
||||||
public static class Embedded {
|
|
||||||
|
|
||||||
private static final AtomicInteger serverIdCounter = new AtomicInteger();
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Server id. By default, an auto-incremented counter is used.
|
|
||||||
*/
|
|
||||||
private int serverId = serverIdCounter.getAndIncrement();
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Enable embedded mode if the HornetQ server APIs are available.
|
|
||||||
*/
|
|
||||||
private boolean enabled = true;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Enable persistent store.
|
|
||||||
*/
|
|
||||||
private boolean persistent;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Journal file directory. Not necessary if persistence is turned off.
|
|
||||||
*/
|
|
||||||
private String dataDirectory;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Comma-separated list of queues to create on startup.
|
|
||||||
*/
|
|
||||||
private String[] queues = new String[0];
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Comma-separated list of topics to create on startup.
|
|
||||||
*/
|
|
||||||
private String[] topics = new String[0];
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Cluster password. Randomly generated on startup by default.
|
|
||||||
*/
|
|
||||||
private String clusterPassword = UUID.randomUUID().toString();
|
|
||||||
|
|
||||||
private boolean defaultClusterPassword = true;
|
|
||||||
|
|
||||||
public int getServerId() {
|
|
||||||
return this.serverId;
|
|
||||||
}
|
|
||||||
|
|
||||||
public void setServerId(int serverId) {
|
|
||||||
this.serverId = serverId;
|
|
||||||
}
|
|
||||||
|
|
||||||
public boolean isEnabled() {
|
|
||||||
return this.enabled;
|
|
||||||
}
|
|
||||||
|
|
||||||
public void setEnabled(boolean enabled) {
|
|
||||||
this.enabled = enabled;
|
|
||||||
}
|
|
||||||
|
|
||||||
public boolean isPersistent() {
|
|
||||||
return this.persistent;
|
|
||||||
}
|
|
||||||
|
|
||||||
public void setPersistent(boolean persistent) {
|
|
||||||
this.persistent = persistent;
|
|
||||||
}
|
|
||||||
|
|
||||||
public String getDataDirectory() {
|
|
||||||
return this.dataDirectory;
|
|
||||||
}
|
|
||||||
|
|
||||||
public void setDataDirectory(String dataDirectory) {
|
|
||||||
this.dataDirectory = dataDirectory;
|
|
||||||
}
|
|
||||||
|
|
||||||
public String[] getQueues() {
|
|
||||||
return this.queues;
|
|
||||||
}
|
|
||||||
|
|
||||||
public void setQueues(String[] queues) {
|
|
||||||
this.queues = queues;
|
|
||||||
}
|
|
||||||
|
|
||||||
public String[] getTopics() {
|
|
||||||
return this.topics;
|
|
||||||
}
|
|
||||||
|
|
||||||
public void setTopics(String[] topics) {
|
|
||||||
this.topics = topics;
|
|
||||||
}
|
|
||||||
|
|
||||||
public String getClusterPassword() {
|
|
||||||
return this.clusterPassword;
|
|
||||||
}
|
|
||||||
|
|
||||||
public void setClusterPassword(String clusterPassword) {
|
|
||||||
this.clusterPassword = clusterPassword;
|
|
||||||
this.defaultClusterPassword = false;
|
|
||||||
}
|
|
||||||
|
|
||||||
public boolean isDefaultClusterPassword() {
|
|
||||||
return this.defaultClusterPassword;
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Creates the minimal transport parameters for an embedded transport
|
|
||||||
* configuration.
|
|
||||||
*
|
|
||||||
* @return the transport parameters
|
|
||||||
* @see TransportConstants#SERVER_ID_PROP_NAME
|
|
||||||
*/
|
|
||||||
public Map<String, Object> generateTransportParameters() {
|
|
||||||
Map<String, Object> parameters = new HashMap<String, Object>();
|
|
||||||
parameters.put(TransportConstants.SERVER_ID_PROP_NAME, getServerId());
|
|
||||||
return parameters;
|
|
||||||
}
|
|
||||||
|
|
||||||
}
|
|
||||||
|
|
||||||
}
|
|
||||||
@ -1,64 +0,0 @@
|
|||||||
/*
|
|
||||||
* Copyright 2012-2016 the original author or authors.
|
|
||||||
*
|
|
||||||
* Licensed under the Apache License, Version 2.0 (the "License");
|
|
||||||
* you may not use this file except in compliance with the License.
|
|
||||||
* You may obtain a copy of the License at
|
|
||||||
*
|
|
||||||
* http://www.apache.org/licenses/LICENSE-2.0
|
|
||||||
*
|
|
||||||
* Unless required by applicable law or agreed to in writing, software
|
|
||||||
* distributed under the License is distributed on an "AS IS" BASIS,
|
|
||||||
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
||||||
* See the License for the specific language governing permissions and
|
|
||||||
* limitations under the License.
|
|
||||||
*/
|
|
||||||
|
|
||||||
package org.springframework.boot.autoconfigure.jms.hornetq;
|
|
||||||
|
|
||||||
import javax.jms.ConnectionFactory;
|
|
||||||
import javax.transaction.TransactionManager;
|
|
||||||
|
|
||||||
import org.hornetq.jms.client.HornetQConnectionFactory;
|
|
||||||
|
|
||||||
import org.springframework.beans.factory.ListableBeanFactory;
|
|
||||||
import org.springframework.boot.autoconfigure.condition.ConditionalOnBean;
|
|
||||||
import org.springframework.boot.autoconfigure.condition.ConditionalOnClass;
|
|
||||||
import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
|
|
||||||
import org.springframework.boot.jta.XAConnectionFactoryWrapper;
|
|
||||||
import org.springframework.context.annotation.Bean;
|
|
||||||
import org.springframework.context.annotation.Configuration;
|
|
||||||
import org.springframework.context.annotation.Primary;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Configuration for HornetQ XA {@link ConnectionFactory}.
|
|
||||||
*
|
|
||||||
* @author Phillip Webb
|
|
||||||
* @since 1.2.0
|
|
||||||
* @deprecated as of 1.4 in favor of the Artemis support
|
|
||||||
*/
|
|
||||||
@Configuration
|
|
||||||
@ConditionalOnMissingBean(ConnectionFactory.class)
|
|
||||||
@ConditionalOnClass(TransactionManager.class)
|
|
||||||
@ConditionalOnBean(XAConnectionFactoryWrapper.class)
|
|
||||||
@Deprecated
|
|
||||||
class HornetQXAConnectionFactoryConfiguration {
|
|
||||||
|
|
||||||
@Primary
|
|
||||||
@Bean(name = { "jmsConnectionFactory", "xaJmsConnectionFactory" })
|
|
||||||
public ConnectionFactory jmsConnectionFactory(ListableBeanFactory beanFactory,
|
|
||||||
HornetQProperties properties, XAConnectionFactoryWrapper wrapper)
|
|
||||||
throws Exception {
|
|
||||||
return wrapper.wrapConnectionFactory(
|
|
||||||
new HornetQConnectionFactoryFactory(beanFactory, properties)
|
|
||||||
.createConnectionFactory(
|
|
||||||
SpringBootHornetQXAConnectionFactory.class));
|
|
||||||
}
|
|
||||||
|
|
||||||
@Bean
|
|
||||||
public HornetQConnectionFactory nonXaJmsConnectionFactory(
|
|
||||||
ListableBeanFactory beanFactory, HornetQProperties properties) {
|
|
||||||
return new HornetQConnectionFactoryFactory(beanFactory, properties)
|
|
||||||
.createConnectionFactory(SpringBootHornetQConnectionFactory.class);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
@ -1,61 +0,0 @@
|
|||||||
/*
|
|
||||||
* Copyright 2012-2016 the original author or authors.
|
|
||||||
*
|
|
||||||
* Licensed under the Apache License, Version 2.0 (the "License");
|
|
||||||
* you may not use this file except in compliance with the License.
|
|
||||||
* You may obtain a copy of the License at
|
|
||||||
*
|
|
||||||
* http://www.apache.org/licenses/LICENSE-2.0
|
|
||||||
*
|
|
||||||
* Unless required by applicable law or agreed to in writing, software
|
|
||||||
* distributed under the License is distributed on an "AS IS" BASIS,
|
|
||||||
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
||||||
* See the License for the specific language governing permissions and
|
|
||||||
* limitations under the License.
|
|
||||||
*/
|
|
||||||
|
|
||||||
package org.springframework.boot.autoconfigure.jms.hornetq;
|
|
||||||
|
|
||||||
import javax.jms.Connection;
|
|
||||||
import javax.jms.JMSException;
|
|
||||||
|
|
||||||
import org.hornetq.api.core.TransportConfiguration;
|
|
||||||
import org.hornetq.api.core.client.ServerLocator;
|
|
||||||
import org.hornetq.jms.client.HornetQConnectionFactory;
|
|
||||||
|
|
||||||
import org.springframework.util.StringUtils;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* A {@link HornetQConnectionFactory} that manages the credentials of the connection.
|
|
||||||
*
|
|
||||||
* @author Stéphane Lagraulet
|
|
||||||
* @author Stephane Nicoll
|
|
||||||
* @deprecated as of 1.4 in favor of the Artemis support
|
|
||||||
*/
|
|
||||||
@Deprecated
|
|
||||||
class SpringBootHornetQConnectionFactory extends HornetQConnectionFactory {
|
|
||||||
|
|
||||||
private final HornetQProperties properties;
|
|
||||||
|
|
||||||
SpringBootHornetQConnectionFactory(HornetQProperties properties,
|
|
||||||
ServerLocator serverLocator) {
|
|
||||||
super(serverLocator);
|
|
||||||
this.properties = properties;
|
|
||||||
}
|
|
||||||
|
|
||||||
SpringBootHornetQConnectionFactory(HornetQProperties properties, boolean ha,
|
|
||||||
TransportConfiguration... initialConnectors) {
|
|
||||||
super(ha, initialConnectors);
|
|
||||||
this.properties = properties;
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public Connection createConnection() throws JMSException {
|
|
||||||
String user = this.properties.getUser();
|
|
||||||
if (StringUtils.hasText(user)) {
|
|
||||||
return createConnection(user, this.properties.getPassword());
|
|
||||||
}
|
|
||||||
return super.createConnection();
|
|
||||||
}
|
|
||||||
|
|
||||||
}
|
|
||||||
@ -1,61 +0,0 @@
|
|||||||
/*
|
|
||||||
* Copyright 2012-2016 the original author or authors.
|
|
||||||
*
|
|
||||||
* Licensed under the Apache License, Version 2.0 (the "License");
|
|
||||||
* you may not use this file except in compliance with the License.
|
|
||||||
* You may obtain a copy of the License at
|
|
||||||
*
|
|
||||||
* http://www.apache.org/licenses/LICENSE-2.0
|
|
||||||
*
|
|
||||||
* Unless required by applicable law or agreed to in writing, software
|
|
||||||
* distributed under the License is distributed on an "AS IS" BASIS,
|
|
||||||
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
||||||
* See the License for the specific language governing permissions and
|
|
||||||
* limitations under the License.
|
|
||||||
*/
|
|
||||||
|
|
||||||
package org.springframework.boot.autoconfigure.jms.hornetq;
|
|
||||||
|
|
||||||
import javax.jms.Connection;
|
|
||||||
import javax.jms.JMSException;
|
|
||||||
|
|
||||||
import org.hornetq.api.core.TransportConfiguration;
|
|
||||||
import org.hornetq.api.core.client.ServerLocator;
|
|
||||||
import org.hornetq.jms.client.HornetQXAConnectionFactory;
|
|
||||||
|
|
||||||
import org.springframework.util.StringUtils;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* A {@link HornetQXAConnectionFactory} that manages the credentials of the connection.
|
|
||||||
*
|
|
||||||
* @author Stéphane Lagraulet
|
|
||||||
* @author Stephane Nicoll
|
|
||||||
* @deprecated as of 1.4 in favor of the Artemis support
|
|
||||||
*/
|
|
||||||
@Deprecated
|
|
||||||
class SpringBootHornetQXAConnectionFactory extends HornetQXAConnectionFactory {
|
|
||||||
|
|
||||||
private final HornetQProperties properties;
|
|
||||||
|
|
||||||
SpringBootHornetQXAConnectionFactory(HornetQProperties properties,
|
|
||||||
ServerLocator serverLocator) {
|
|
||||||
super(serverLocator);
|
|
||||||
this.properties = properties;
|
|
||||||
}
|
|
||||||
|
|
||||||
SpringBootHornetQXAConnectionFactory(HornetQProperties properties, boolean ha,
|
|
||||||
TransportConfiguration... initialConnectors) {
|
|
||||||
super(ha, initialConnectors);
|
|
||||||
this.properties = properties;
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public Connection createConnection() throws JMSException {
|
|
||||||
String user = this.properties.getUser();
|
|
||||||
if (StringUtils.hasText(user)) {
|
|
||||||
return createConnection(user, this.properties.getPassword());
|
|
||||||
}
|
|
||||||
return super.createConnection();
|
|
||||||
}
|
|
||||||
|
|
||||||
}
|
|
||||||
@ -1,21 +0,0 @@
|
|||||||
/*
|
|
||||||
* Copyright 2012-2016 the original author or authors.
|
|
||||||
*
|
|
||||||
* Licensed under the Apache License, Version 2.0 (the "License");
|
|
||||||
* you may not use this file except in compliance with the License.
|
|
||||||
* You may obtain a copy of the License at
|
|
||||||
*
|
|
||||||
* http://www.apache.org/licenses/LICENSE-2.0
|
|
||||||
*
|
|
||||||
* Unless required by applicable law or agreed to in writing, software
|
|
||||||
* distributed under the License is distributed on an "AS IS" BASIS,
|
|
||||||
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
||||||
* See the License for the specific language governing permissions and
|
|
||||||
* limitations under the License.
|
|
||||||
*/
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Auto-configuration for HornetQ.
|
|
||||||
* @deprecated as of 1.4 in favor of the Artemis support
|
|
||||||
*/
|
|
||||||
package org.springframework.boot.autoconfigure.jms.hornetq;
|
|
||||||
@ -1,435 +0,0 @@
|
|||||||
/*
|
|
||||||
* Copyright 2012-2016 the original author or authors.
|
|
||||||
*
|
|
||||||
* Licensed under the Apache License, Version 2.0 (the "License");
|
|
||||||
* you may not use this file except in compliance with the License.
|
|
||||||
* You may obtain a copy of the License at
|
|
||||||
*
|
|
||||||
* http://www.apache.org/licenses/LICENSE-2.0
|
|
||||||
*
|
|
||||||
* Unless required by applicable law or agreed to in writing, software
|
|
||||||
* distributed under the License is distributed on an "AS IS" BASIS,
|
|
||||||
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
||||||
* See the License for the specific language governing permissions and
|
|
||||||
* limitations under the License.
|
|
||||||
*/
|
|
||||||
|
|
||||||
package org.springframework.boot.autoconfigure.jms.hornetq;
|
|
||||||
|
|
||||||
import java.io.File;
|
|
||||||
import java.io.IOException;
|
|
||||||
import java.util.UUID;
|
|
||||||
|
|
||||||
import javax.jms.Connection;
|
|
||||||
import javax.jms.Destination;
|
|
||||||
import javax.jms.JMSException;
|
|
||||||
import javax.jms.Message;
|
|
||||||
import javax.jms.Session;
|
|
||||||
import javax.jms.TextMessage;
|
|
||||||
|
|
||||||
import org.hornetq.api.core.TransportConfiguration;
|
|
||||||
import org.hornetq.core.remoting.impl.invm.InVMConnectorFactory;
|
|
||||||
import org.hornetq.core.remoting.impl.netty.NettyConnectorFactory;
|
|
||||||
import org.hornetq.jms.client.HornetQConnectionFactory;
|
|
||||||
import org.hornetq.jms.server.config.JMSConfiguration;
|
|
||||||
import org.hornetq.jms.server.config.JMSQueueConfiguration;
|
|
||||||
import org.hornetq.jms.server.config.TopicConfiguration;
|
|
||||||
import org.hornetq.jms.server.config.impl.JMSConfigurationImpl;
|
|
||||||
import org.hornetq.jms.server.config.impl.JMSQueueConfigurationImpl;
|
|
||||||
import org.hornetq.jms.server.config.impl.TopicConfigurationImpl;
|
|
||||||
import org.hornetq.jms.server.embedded.EmbeddedJMS;
|
|
||||||
import org.junit.After;
|
|
||||||
import org.junit.Rule;
|
|
||||||
import org.junit.Test;
|
|
||||||
import org.junit.rules.TemporaryFolder;
|
|
||||||
|
|
||||||
import org.springframework.boot.autoconfigure.jms.JmsAutoConfiguration;
|
|
||||||
import org.springframework.boot.test.util.EnvironmentTestUtils;
|
|
||||||
import org.springframework.context.ApplicationContext;
|
|
||||||
import org.springframework.context.annotation.AnnotationConfigApplicationContext;
|
|
||||||
import org.springframework.context.annotation.Bean;
|
|
||||||
import org.springframework.context.annotation.Configuration;
|
|
||||||
import org.springframework.jms.core.JmsTemplate;
|
|
||||||
import org.springframework.jms.core.MessageCreator;
|
|
||||||
import org.springframework.jms.core.SessionCallback;
|
|
||||||
import org.springframework.jms.support.destination.DestinationResolver;
|
|
||||||
import org.springframework.jms.support.destination.DynamicDestinationResolver;
|
|
||||||
|
|
||||||
import static org.assertj.core.api.Assertions.assertThat;
|
|
||||||
import static org.mockito.Mockito.doReturn;
|
|
||||||
import static org.mockito.Mockito.mock;
|
|
||||||
import static org.mockito.Mockito.spy;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Tests for {@link HornetQAutoConfiguration}.
|
|
||||||
*
|
|
||||||
* @author Stephane Nicoll
|
|
||||||
*/
|
|
||||||
@Deprecated
|
|
||||||
@SuppressWarnings("deprecation")
|
|
||||||
public class HornetQAutoConfigurationTests {
|
|
||||||
|
|
||||||
@Rule
|
|
||||||
public final TemporaryFolder folder = new TemporaryFolder();
|
|
||||||
|
|
||||||
private AnnotationConfigApplicationContext context;
|
|
||||||
|
|
||||||
@After
|
|
||||||
public void tearDown() {
|
|
||||||
if (this.context != null) {
|
|
||||||
this.context.close();
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
@Test
|
|
||||||
public void nativeConnectionFactory() {
|
|
||||||
load(EmptyConfiguration.class, "spring.hornetq.mode:native");
|
|
||||||
JmsTemplate jmsTemplate = this.context.getBean(JmsTemplate.class);
|
|
||||||
HornetQConnectionFactory connectionFactory = this.context
|
|
||||||
.getBean(HornetQConnectionFactory.class);
|
|
||||||
assertThat(connectionFactory).isEqualTo(jmsTemplate.getConnectionFactory());
|
|
||||||
assertNettyConnectionFactory(connectionFactory, "localhost", 5445);
|
|
||||||
}
|
|
||||||
|
|
||||||
@Test
|
|
||||||
public void nativeConnectionFactoryCustomHost() {
|
|
||||||
load(EmptyConfiguration.class, "spring.hornetq.mode:native",
|
|
||||||
"spring.hornetq.host:192.168.1.144", "spring.hornetq.port:9876");
|
|
||||||
HornetQConnectionFactory connectionFactory = this.context
|
|
||||||
.getBean(HornetQConnectionFactory.class);
|
|
||||||
assertNettyConnectionFactory(connectionFactory, "192.168.1.144", 9876);
|
|
||||||
}
|
|
||||||
|
|
||||||
@Test
|
|
||||||
public void nativeConnectionFactoryCredentials() throws JMSException {
|
|
||||||
load(EmptyConfiguration.class, "spring.hornetq.mode:native",
|
|
||||||
"spring.hornetq.user:user", "spring.hornetq.password:secret");
|
|
||||||
HornetQConnectionFactory connectionFactory = this.context
|
|
||||||
.getBean(HornetQConnectionFactory.class);
|
|
||||||
|
|
||||||
// Validate the secured variant is invoked
|
|
||||||
HornetQConnectionFactory testCf = spy(connectionFactory);
|
|
||||||
Connection connection = mock(Connection.class);
|
|
||||||
doReturn(connection).when(testCf).createConnection("user", "secret");
|
|
||||||
|
|
||||||
Connection actual = testCf.createConnection();
|
|
||||||
assertThat(actual).isSameAs(connection);
|
|
||||||
}
|
|
||||||
|
|
||||||
@Test
|
|
||||||
public void embeddedConnectionFactory() {
|
|
||||||
load(EmptyConfiguration.class, "spring.hornetq.mode:embedded");
|
|
||||||
|
|
||||||
HornetQProperties properties = this.context.getBean(HornetQProperties.class);
|
|
||||||
assertThat(properties.getMode()).isEqualTo(HornetQMode.EMBEDDED);
|
|
||||||
|
|
||||||
assertThat(this.context.getBeansOfType(EmbeddedJMS.class)).hasSize(1);
|
|
||||||
org.hornetq.core.config.Configuration configuration = this.context
|
|
||||||
.getBean(org.hornetq.core.config.Configuration.class);
|
|
||||||
assertThat(configuration.isPersistenceEnabled()).isFalse();
|
|
||||||
assertThat(configuration.isSecurityEnabled()).isFalse();
|
|
||||||
|
|
||||||
HornetQConnectionFactory connectionFactory = this.context
|
|
||||||
.getBean(HornetQConnectionFactory.class);
|
|
||||||
assertInVmConnectionFactory(connectionFactory);
|
|
||||||
}
|
|
||||||
|
|
||||||
@Test
|
|
||||||
public void embeddedConnectionFactoryByDefault() {
|
|
||||||
// No mode is specified
|
|
||||||
load(EmptyConfiguration.class);
|
|
||||||
|
|
||||||
assertThat(this.context.getBeansOfType(EmbeddedJMS.class)).hasSize(1);
|
|
||||||
org.hornetq.core.config.Configuration configuration = this.context
|
|
||||||
.getBean(org.hornetq.core.config.Configuration.class);
|
|
||||||
assertThat(configuration.isPersistenceEnabled()).isFalse();
|
|
||||||
assertThat(configuration.isSecurityEnabled()).isFalse();
|
|
||||||
|
|
||||||
HornetQConnectionFactory connectionFactory = this.context
|
|
||||||
.getBean(HornetQConnectionFactory.class);
|
|
||||||
assertInVmConnectionFactory(connectionFactory);
|
|
||||||
}
|
|
||||||
|
|
||||||
@Test
|
|
||||||
public void nativeConnectionFactoryIfEmbeddedServiceDisabledExplicitly() {
|
|
||||||
// No mode is specified
|
|
||||||
load(EmptyConfiguration.class, "spring.hornetq.embedded.enabled:false");
|
|
||||||
|
|
||||||
assertThat(this.context.getBeansOfType(EmbeddedJMS.class)).isEmpty();
|
|
||||||
|
|
||||||
HornetQConnectionFactory connectionFactory = this.context
|
|
||||||
.getBean(HornetQConnectionFactory.class);
|
|
||||||
assertNettyConnectionFactory(connectionFactory, "localhost", 5445);
|
|
||||||
}
|
|
||||||
|
|
||||||
@Test
|
|
||||||
public void embeddedConnectionFactoryEvenIfEmbeddedServiceDisabled() {
|
|
||||||
// No mode is specified
|
|
||||||
load(EmptyConfiguration.class, "spring.hornetq.mode:embedded",
|
|
||||||
"spring.hornetq.embedded.enabled:false");
|
|
||||||
|
|
||||||
assertThat(this.context.getBeansOfType(EmbeddedJMS.class)).isEmpty();
|
|
||||||
|
|
||||||
HornetQConnectionFactory connectionFactory = this.context
|
|
||||||
.getBean(HornetQConnectionFactory.class);
|
|
||||||
assertInVmConnectionFactory(connectionFactory);
|
|
||||||
}
|
|
||||||
|
|
||||||
@Test
|
|
||||||
public void embeddedServerWithDestinations() {
|
|
||||||
load(EmptyConfiguration.class, "spring.hornetq.embedded.queues=Queue1,Queue2",
|
|
||||||
"spring.hornetq.embedded.topics=Topic1");
|
|
||||||
|
|
||||||
DestinationChecker checker = new DestinationChecker(this.context);
|
|
||||||
checker.checkQueue("Queue1", true);
|
|
||||||
checker.checkQueue("Queue2", true);
|
|
||||||
checker.checkQueue("QueueDoesNotExist", false);
|
|
||||||
|
|
||||||
checker.checkTopic("Topic1", true);
|
|
||||||
checker.checkTopic("TopicDoesNotExist", false);
|
|
||||||
}
|
|
||||||
|
|
||||||
@Test
|
|
||||||
public void embeddedServerWithDestinationConfig() {
|
|
||||||
load(DestinationConfiguration.class);
|
|
||||||
|
|
||||||
DestinationChecker checker = new DestinationChecker(this.context);
|
|
||||||
checker.checkQueue("sampleQueue", true);
|
|
||||||
checker.checkTopic("sampleTopic", true);
|
|
||||||
}
|
|
||||||
|
|
||||||
@Test
|
|
||||||
public void embeddedServiceWithCustomJmsConfiguration() {
|
|
||||||
// Ignored with custom config
|
|
||||||
load(CustomJmsConfiguration.class,
|
|
||||||
"spring.hornetq.embedded.queues=Queue1,Queue2");
|
|
||||||
DestinationChecker checker = new DestinationChecker(this.context);
|
|
||||||
checker.checkQueue("custom", true); // See CustomJmsConfiguration
|
|
||||||
|
|
||||||
checker.checkQueue("Queue1", false);
|
|
||||||
checker.checkQueue("Queue2", false);
|
|
||||||
}
|
|
||||||
|
|
||||||
@Test
|
|
||||||
public void embeddedServiceWithCustomHornetQConfiguration() {
|
|
||||||
load(CustomHornetQConfiguration.class);
|
|
||||||
org.hornetq.core.config.Configuration configuration = this.context
|
|
||||||
.getBean(org.hornetq.core.config.Configuration.class);
|
|
||||||
assertThat(configuration.getName()).isEqualTo("customFooBar");
|
|
||||||
}
|
|
||||||
|
|
||||||
@Test
|
|
||||||
public void embeddedWithPersistentMode() throws IOException, JMSException {
|
|
||||||
File dataFolder = this.folder.newFolder();
|
|
||||||
|
|
||||||
// Start the server and post a message to some queue
|
|
||||||
load(EmptyConfiguration.class, "spring.hornetq.embedded.queues=TestQueue",
|
|
||||||
"spring.hornetq.embedded.persistent:true",
|
|
||||||
"spring.hornetq.embedded.dataDirectory:" + dataFolder.getAbsolutePath());
|
|
||||||
|
|
||||||
final String msgId = UUID.randomUUID().toString();
|
|
||||||
JmsTemplate jmsTemplate = this.context.getBean(JmsTemplate.class);
|
|
||||||
jmsTemplate.send("TestQueue", new MessageCreator() {
|
|
||||||
@Override
|
|
||||||
public Message createMessage(Session session) throws JMSException {
|
|
||||||
return session.createTextMessage(msgId);
|
|
||||||
}
|
|
||||||
});
|
|
||||||
this.context.close(); // Shutdown the broker
|
|
||||||
|
|
||||||
// Start the server again and check if our message is still here
|
|
||||||
load(EmptyConfiguration.class, "spring.hornetq.embedded.queues=TestQueue",
|
|
||||||
"spring.hornetq.embedded.persistent:true",
|
|
||||||
"spring.hornetq.embedded.dataDirectory:" + dataFolder.getAbsolutePath());
|
|
||||||
|
|
||||||
JmsTemplate jmsTemplate2 = this.context.getBean(JmsTemplate.class);
|
|
||||||
jmsTemplate2.setReceiveTimeout(1000L);
|
|
||||||
Message message = jmsTemplate2.receive("TestQueue");
|
|
||||||
assertThat(message).isNotNull();
|
|
||||||
assertThat(((TextMessage) message).getText()).isEqualTo(msgId);
|
|
||||||
}
|
|
||||||
|
|
||||||
@Test
|
|
||||||
public void severalEmbeddedBrokers() {
|
|
||||||
load(EmptyConfiguration.class, "spring.hornetq.embedded.queues=Queue1");
|
|
||||||
|
|
||||||
AnnotationConfigApplicationContext anotherContext = doLoad(
|
|
||||||
EmptyConfiguration.class, "spring.hornetq.embedded.queues=Queue2");
|
|
||||||
|
|
||||||
try {
|
|
||||||
HornetQProperties properties = this.context.getBean(HornetQProperties.class);
|
|
||||||
HornetQProperties anotherProperties = anotherContext
|
|
||||||
.getBean(HornetQProperties.class);
|
|
||||||
assertThat(properties.getEmbedded().getServerId() < anotherProperties
|
|
||||||
.getEmbedded().getServerId()).isTrue();
|
|
||||||
|
|
||||||
DestinationChecker checker = new DestinationChecker(this.context);
|
|
||||||
checker.checkQueue("Queue1", true);
|
|
||||||
checker.checkQueue("Queue2", false);
|
|
||||||
|
|
||||||
DestinationChecker anotherChecker = new DestinationChecker(anotherContext);
|
|
||||||
anotherChecker.checkQueue("Queue2", true);
|
|
||||||
anotherChecker.checkQueue("Queue1", false);
|
|
||||||
}
|
|
||||||
finally {
|
|
||||||
anotherContext.close();
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
@Test
|
|
||||||
public void connectToASpecificEmbeddedBroker() {
|
|
||||||
load(EmptyConfiguration.class, "spring.hornetq.embedded.serverId=93",
|
|
||||||
"spring.hornetq.embedded.queues=Queue1");
|
|
||||||
|
|
||||||
AnnotationConfigApplicationContext anotherContext = doLoad(
|
|
||||||
EmptyConfiguration.class, "spring.hornetq.mode=embedded",
|
|
||||||
"spring.hornetq.embedded.serverId=93", // Connect to the "main" broker
|
|
||||||
"spring.hornetq.embedded.enabled=false"); // do not start a specific one
|
|
||||||
|
|
||||||
try {
|
|
||||||
DestinationChecker checker = new DestinationChecker(this.context);
|
|
||||||
checker.checkQueue("Queue1", true);
|
|
||||||
|
|
||||||
DestinationChecker anotherChecker = new DestinationChecker(anotherContext);
|
|
||||||
anotherChecker.checkQueue("Queue1", true);
|
|
||||||
}
|
|
||||||
finally {
|
|
||||||
anotherContext.close();
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
private TransportConfiguration assertInVmConnectionFactory(
|
|
||||||
HornetQConnectionFactory connectionFactory) {
|
|
||||||
TransportConfiguration transportConfig = getSingleTransportConfiguration(
|
|
||||||
connectionFactory);
|
|
||||||
assertThat(transportConfig.getFactoryClassName())
|
|
||||||
.isEqualTo(InVMConnectorFactory.class.getName());
|
|
||||||
return transportConfig;
|
|
||||||
}
|
|
||||||
|
|
||||||
private TransportConfiguration assertNettyConnectionFactory(
|
|
||||||
HornetQConnectionFactory connectionFactory, String host, int port) {
|
|
||||||
TransportConfiguration transportConfig = getSingleTransportConfiguration(
|
|
||||||
connectionFactory);
|
|
||||||
assertThat(transportConfig.getFactoryClassName())
|
|
||||||
.isEqualTo(NettyConnectorFactory.class.getName());
|
|
||||||
assertThat(transportConfig.getParams().get("host")).isEqualTo(host);
|
|
||||||
assertThat(transportConfig.getParams().get("port")).isEqualTo(port);
|
|
||||||
return transportConfig;
|
|
||||||
}
|
|
||||||
|
|
||||||
private TransportConfiguration getSingleTransportConfiguration(
|
|
||||||
HornetQConnectionFactory connectionFactory) {
|
|
||||||
TransportConfiguration[] transportConfigurations = connectionFactory
|
|
||||||
.getServerLocator().getStaticTransportConfigurations();
|
|
||||||
assertThat(transportConfigurations.length).isEqualTo(1);
|
|
||||||
return transportConfigurations[0];
|
|
||||||
}
|
|
||||||
|
|
||||||
private void load(Class<?> config, String... environment) {
|
|
||||||
this.context = doLoad(config, environment);
|
|
||||||
}
|
|
||||||
|
|
||||||
private AnnotationConfigApplicationContext doLoad(Class<?> config,
|
|
||||||
String... environment) {
|
|
||||||
AnnotationConfigApplicationContext applicationContext = new AnnotationConfigApplicationContext();
|
|
||||||
applicationContext.register(config);
|
|
||||||
applicationContext.register(HornetQAutoConfiguration.class,
|
|
||||||
JmsAutoConfiguration.class);
|
|
||||||
EnvironmentTestUtils.addEnvironment(applicationContext, environment);
|
|
||||||
applicationContext.refresh();
|
|
||||||
return applicationContext;
|
|
||||||
}
|
|
||||||
|
|
||||||
private final static class DestinationChecker {
|
|
||||||
|
|
||||||
private final JmsTemplate jmsTemplate;
|
|
||||||
|
|
||||||
private final DestinationResolver destinationResolver;
|
|
||||||
|
|
||||||
private DestinationChecker(ApplicationContext applicationContext) {
|
|
||||||
this.jmsTemplate = applicationContext.getBean(JmsTemplate.class);
|
|
||||||
this.destinationResolver = new DynamicDestinationResolver();
|
|
||||||
}
|
|
||||||
|
|
||||||
public void checkQueue(String name, boolean shouldExist) {
|
|
||||||
checkDestination(name, false, shouldExist);
|
|
||||||
}
|
|
||||||
|
|
||||||
public void checkTopic(String name, boolean shouldExist) {
|
|
||||||
checkDestination(name, true, shouldExist);
|
|
||||||
}
|
|
||||||
|
|
||||||
public void checkDestination(final String name, final boolean pubSub,
|
|
||||||
final boolean shouldExist) {
|
|
||||||
this.jmsTemplate.execute(new SessionCallback<Void>() {
|
|
||||||
@Override
|
|
||||||
public Void doInJms(Session session) throws JMSException {
|
|
||||||
try {
|
|
||||||
Destination destination = DestinationChecker.this.destinationResolver
|
|
||||||
.resolveDestinationName(session, name, pubSub);
|
|
||||||
if (!shouldExist) {
|
|
||||||
throw new IllegalStateException("Destination '" + name
|
|
||||||
+ "' was not expected but got " + destination);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
catch (JMSException e) {
|
|
||||||
if (shouldExist) {
|
|
||||||
throw new IllegalStateException("Destination '" + name
|
|
||||||
+ "' was expected but got " + e.getMessage());
|
|
||||||
}
|
|
||||||
}
|
|
||||||
return null;
|
|
||||||
}
|
|
||||||
});
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
@Configuration
|
|
||||||
protected static class EmptyConfiguration {
|
|
||||||
}
|
|
||||||
|
|
||||||
@Configuration
|
|
||||||
protected static class DestinationConfiguration {
|
|
||||||
|
|
||||||
@Bean
|
|
||||||
JMSQueueConfiguration sampleQueueConfiguration() {
|
|
||||||
return new JMSQueueConfigurationImpl("sampleQueue", "foo=bar", false,
|
|
||||||
"/queue/1");
|
|
||||||
}
|
|
||||||
|
|
||||||
@Bean
|
|
||||||
TopicConfiguration sampleTopicConfiguration() {
|
|
||||||
return new TopicConfigurationImpl("sampleTopic", "/topic/1");
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
@Configuration
|
|
||||||
protected static class CustomJmsConfiguration {
|
|
||||||
|
|
||||||
@Bean
|
|
||||||
public JMSConfiguration myJmsConfiguration() {
|
|
||||||
JMSConfiguration config = new JMSConfigurationImpl();
|
|
||||||
config.getQueueConfigurations()
|
|
||||||
.add(new JMSQueueConfigurationImpl("custom", null, false));
|
|
||||||
return config;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
@Configuration
|
|
||||||
protected static class CustomHornetQConfiguration {
|
|
||||||
|
|
||||||
@Bean
|
|
||||||
public HornetQConfigurationCustomizer myHornetQCustomize() {
|
|
||||||
return new HornetQConfigurationCustomizer() {
|
|
||||||
@Override
|
|
||||||
public void customize(
|
|
||||||
org.hornetq.core.config.Configuration configuration) {
|
|
||||||
configuration.setClusterPassword("Foobar");
|
|
||||||
configuration.setName("customFooBar");
|
|
||||||
}
|
|
||||||
};
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
}
|
|
||||||
@ -1,71 +0,0 @@
|
|||||||
/*
|
|
||||||
* Copyright 2012-2016 the original author or authors.
|
|
||||||
*
|
|
||||||
* Licensed under the Apache License, Version 2.0 (the "License");
|
|
||||||
* you may not use this file except in compliance with the License.
|
|
||||||
* You may obtain a copy of the License at
|
|
||||||
*
|
|
||||||
* http://www.apache.org/licenses/LICENSE-2.0
|
|
||||||
*
|
|
||||||
* Unless required by applicable law or agreed to in writing, software
|
|
||||||
* distributed under the License is distributed on an "AS IS" BASIS,
|
|
||||||
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
||||||
* See the License for the specific language governing permissions and
|
|
||||||
* limitations under the License.
|
|
||||||
*/
|
|
||||||
|
|
||||||
package org.springframework.boot.autoconfigure.jms.hornetq;
|
|
||||||
|
|
||||||
import org.hornetq.core.config.Configuration;
|
|
||||||
import org.hornetq.core.server.JournalType;
|
|
||||||
import org.junit.Test;
|
|
||||||
|
|
||||||
import static org.assertj.core.api.Assertions.assertThat;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Tests for {@link HornetQEmbeddedConfigurationFactory}.
|
|
||||||
*
|
|
||||||
* @author Stephane Nicoll
|
|
||||||
* @author Phillip Webb
|
|
||||||
*/
|
|
||||||
@Deprecated
|
|
||||||
public class HornetQEmbeddedConfigurationFactoryTests {
|
|
||||||
|
|
||||||
@Test
|
|
||||||
public void defaultDataDir() {
|
|
||||||
HornetQProperties properties = new HornetQProperties();
|
|
||||||
properties.getEmbedded().setPersistent(true);
|
|
||||||
Configuration configuration = new HornetQEmbeddedConfigurationFactory(properties)
|
|
||||||
.createConfiguration();
|
|
||||||
assertThat(configuration.getJournalDirectory())
|
|
||||||
.startsWith(System.getProperty("java.io.tmpdir")).endsWith("/journal");
|
|
||||||
}
|
|
||||||
|
|
||||||
@Test
|
|
||||||
public void persistenceSetup() {
|
|
||||||
HornetQProperties properties = new HornetQProperties();
|
|
||||||
properties.getEmbedded().setPersistent(true);
|
|
||||||
Configuration configuration = new HornetQEmbeddedConfigurationFactory(properties)
|
|
||||||
.createConfiguration();
|
|
||||||
assertThat(configuration.isPersistenceEnabled()).isTrue();
|
|
||||||
assertThat(configuration.getJournalType()).isEqualTo(JournalType.NIO);
|
|
||||||
}
|
|
||||||
|
|
||||||
@Test
|
|
||||||
public void generatedClusterPassword() throws Exception {
|
|
||||||
HornetQProperties properties = new HornetQProperties();
|
|
||||||
Configuration configuration = new HornetQEmbeddedConfigurationFactory(properties)
|
|
||||||
.createConfiguration();
|
|
||||||
assertThat(configuration.getClusterPassword().length()).isEqualTo(36);
|
|
||||||
}
|
|
||||||
|
|
||||||
@Test
|
|
||||||
public void specificClusterPassword() throws Exception {
|
|
||||||
HornetQProperties properties = new HornetQProperties();
|
|
||||||
properties.getEmbedded().setClusterPassword("password");
|
|
||||||
Configuration configuration = new HornetQEmbeddedConfigurationFactory(properties)
|
|
||||||
.createConfiguration();
|
|
||||||
assertThat(configuration.getClusterPassword()).isEqualTo("password");
|
|
||||||
}
|
|
||||||
|
|
||||||
}
|
|
||||||
@ -1,44 +0,0 @@
|
|||||||
<?xml version="1.0" encoding="UTF-8"?>
|
|
||||||
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
|
|
||||||
<modelVersion>4.0.0</modelVersion>
|
|
||||||
<parent>
|
|
||||||
<!-- Your own application should inherit from spring-boot-starter-parent -->
|
|
||||||
<groupId>org.springframework.boot</groupId>
|
|
||||||
<artifactId>spring-boot-samples</artifactId>
|
|
||||||
<version>1.5.0.BUILD-SNAPSHOT</version>
|
|
||||||
</parent>
|
|
||||||
<artifactId>spring-boot-sample-hornetq</artifactId>
|
|
||||||
<name>Spring Boot HornetQ Sample</name>
|
|
||||||
<description>Spring Boot HornetQ Sample</description>
|
|
||||||
<url>http://projects.spring.io/spring-boot/</url>
|
|
||||||
<organization>
|
|
||||||
<name>Pivotal Software, Inc.</name>
|
|
||||||
<url>http://www.spring.io</url>
|
|
||||||
</organization>
|
|
||||||
<properties>
|
|
||||||
<main.basedir>${basedir}/../..</main.basedir>
|
|
||||||
</properties>
|
|
||||||
<dependencies>
|
|
||||||
<dependency>
|
|
||||||
<groupId>org.springframework.boot</groupId>
|
|
||||||
<artifactId>spring-boot-starter-hornetq</artifactId>
|
|
||||||
</dependency>
|
|
||||||
<dependency>
|
|
||||||
<groupId>org.hornetq</groupId>
|
|
||||||
<artifactId>hornetq-jms-server</artifactId>
|
|
||||||
</dependency>
|
|
||||||
<dependency>
|
|
||||||
<groupId>org.springframework.boot</groupId>
|
|
||||||
<artifactId>spring-boot-starter-test</artifactId>
|
|
||||||
<scope>test</scope>
|
|
||||||
</dependency>
|
|
||||||
</dependencies>
|
|
||||||
<build>
|
|
||||||
<plugins>
|
|
||||||
<plugin>
|
|
||||||
<groupId>org.springframework.boot</groupId>
|
|
||||||
<artifactId>spring-boot-maven-plugin</artifactId>
|
|
||||||
</plugin>
|
|
||||||
</plugins>
|
|
||||||
</build>
|
|
||||||
</project>
|
|
||||||
@ -1,65 +0,0 @@
|
|||||||
/*
|
|
||||||
* Copyright 2012-2015 the original author or authors.
|
|
||||||
*
|
|
||||||
* Licensed under the Apache License, Version 2.0 (the "License");
|
|
||||||
* you may not use this file except in compliance with the License.
|
|
||||||
* You may obtain a copy of the License at
|
|
||||||
*
|
|
||||||
* http://www.apache.org/licenses/LICENSE-2.0
|
|
||||||
*
|
|
||||||
* Unless required by applicable law or agreed to in writing, software
|
|
||||||
* distributed under the License is distributed on an "AS IS" BASIS,
|
|
||||||
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
||||||
* See the License for the specific language governing permissions and
|
|
||||||
* limitations under the License.
|
|
||||||
*/
|
|
||||||
|
|
||||||
package sample.hornetq;
|
|
||||||
|
|
||||||
import javax.jms.ConnectionFactory;
|
|
||||||
import javax.jms.JMSException;
|
|
||||||
import javax.jms.Message;
|
|
||||||
import javax.jms.MessageListener;
|
|
||||||
|
|
||||||
import org.springframework.beans.factory.annotation.Autowired;
|
|
||||||
import org.springframework.boot.SpringApplication;
|
|
||||||
import org.springframework.boot.autoconfigure.SpringBootApplication;
|
|
||||||
import org.springframework.context.annotation.Bean;
|
|
||||||
import org.springframework.jms.listener.DefaultMessageListenerContainer;
|
|
||||||
import org.springframework.scheduling.annotation.ScheduledAnnotationBeanPostProcessor;
|
|
||||||
|
|
||||||
@SpringBootApplication
|
|
||||||
public class SampleHornetQApplication {
|
|
||||||
|
|
||||||
@Autowired
|
|
||||||
private ConnectionFactory connectionFactory;
|
|
||||||
|
|
||||||
@Bean
|
|
||||||
public ScheduledAnnotationBeanPostProcessor scheduledAnnotationBeanPostProcessor() {
|
|
||||||
return new ScheduledAnnotationBeanPostProcessor();
|
|
||||||
}
|
|
||||||
|
|
||||||
@Bean
|
|
||||||
public DefaultMessageListenerContainer messageListener() {
|
|
||||||
DefaultMessageListenerContainer container = new DefaultMessageListenerContainer();
|
|
||||||
container.setConnectionFactory(this.connectionFactory);
|
|
||||||
container.setDestinationName("testQueue");
|
|
||||||
container.setMessageListener(new MessageListener() {
|
|
||||||
@Override
|
|
||||||
public void onMessage(Message message) {
|
|
||||||
try {
|
|
||||||
System.out.println(message.getBody(Object.class));
|
|
||||||
}
|
|
||||||
catch (JMSException ex) {
|
|
||||||
ex.printStackTrace();
|
|
||||||
}
|
|
||||||
}
|
|
||||||
});
|
|
||||||
return container;
|
|
||||||
}
|
|
||||||
|
|
||||||
public static void main(String[] args) throws Exception {
|
|
||||||
SpringApplication.run(SampleHornetQApplication.class, args);
|
|
||||||
}
|
|
||||||
|
|
||||||
}
|
|
||||||
@ -1,35 +0,0 @@
|
|||||||
/*
|
|
||||||
* Copyright 2012-2013 the original author or authors.
|
|
||||||
*
|
|
||||||
* Licensed under the Apache License, Version 2.0 (the "License");
|
|
||||||
* you may not use this file except in compliance with the License.
|
|
||||||
* You may obtain a copy of the License at
|
|
||||||
*
|
|
||||||
* http://www.apache.org/licenses/LICENSE-2.0
|
|
||||||
*
|
|
||||||
* Unless required by applicable law or agreed to in writing, software
|
|
||||||
* distributed under the License is distributed on an "AS IS" BASIS,
|
|
||||||
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
||||||
* See the License for the specific language governing permissions and
|
|
||||||
* limitations under the License.
|
|
||||||
*/
|
|
||||||
|
|
||||||
package sample.hornetq;
|
|
||||||
|
|
||||||
import org.springframework.beans.factory.annotation.Autowired;
|
|
||||||
import org.springframework.jms.core.JmsTemplate;
|
|
||||||
import org.springframework.scheduling.annotation.Scheduled;
|
|
||||||
import org.springframework.stereotype.Component;
|
|
||||||
|
|
||||||
@Component
|
|
||||||
public class Sender {
|
|
||||||
|
|
||||||
@Autowired
|
|
||||||
private JmsTemplate jmsTemplate;
|
|
||||||
|
|
||||||
@Scheduled(fixedDelay = 1000L)
|
|
||||||
public void send() {
|
|
||||||
this.jmsTemplate.convertAndSend("testQueue", "Hello");
|
|
||||||
}
|
|
||||||
|
|
||||||
}
|
|
||||||
@ -1,3 +0,0 @@
|
|||||||
spring.hornetq.mode=embedded
|
|
||||||
spring.hornetq.embedded.enabled=true
|
|
||||||
spring.hornetq.embedded.queues=testQueue,anotherQueue
|
|
||||||
@ -1,57 +0,0 @@
|
|||||||
<?xml version="1.0" encoding="UTF-8"?>
|
|
||||||
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
|
|
||||||
<modelVersion>4.0.0</modelVersion>
|
|
||||||
<parent>
|
|
||||||
<groupId>org.springframework.boot</groupId>
|
|
||||||
<artifactId>spring-boot-starters</artifactId>
|
|
||||||
<version>1.5.0.BUILD-SNAPSHOT</version>
|
|
||||||
</parent>
|
|
||||||
<artifactId>spring-boot-starter-hornetq</artifactId>
|
|
||||||
<name>spring-boot-starter-hornetq (DEPRECATED)</name>
|
|
||||||
<description>Starter for JMS messaging using HornetQ. Deprecated as of 1.4 in favor
|
|
||||||
of spring-boot-starter-artemis</description>
|
|
||||||
<url>http://projects.spring.io/spring-boot/</url>
|
|
||||||
<organization>
|
|
||||||
<name>Pivotal Software, Inc.</name>
|
|
||||||
<url>http://www.spring.io</url>
|
|
||||||
</organization>
|
|
||||||
<properties>
|
|
||||||
<main.basedir>${basedir}/../..</main.basedir>
|
|
||||||
</properties>
|
|
||||||
<dependencies>
|
|
||||||
<dependency>
|
|
||||||
<groupId>org.springframework.boot</groupId>
|
|
||||||
<artifactId>spring-boot-starter</artifactId>
|
|
||||||
</dependency>
|
|
||||||
<dependency>
|
|
||||||
<groupId>org.springframework</groupId>
|
|
||||||
<artifactId>spring-jms</artifactId>
|
|
||||||
</dependency>
|
|
||||||
<dependency>
|
|
||||||
<groupId>org.hornetq</groupId>
|
|
||||||
<artifactId>hornetq-jms-client</artifactId>
|
|
||||||
</dependency>
|
|
||||||
</dependencies>
|
|
||||||
<build>
|
|
||||||
<plugins>
|
|
||||||
<plugin>
|
|
||||||
<groupId>org.basepom.maven</groupId>
|
|
||||||
<artifactId>duplicate-finder-maven-plugin</artifactId>
|
|
||||||
<executions>
|
|
||||||
<execution>
|
|
||||||
<id>duplicate-dependencies</id>
|
|
||||||
<phase>validate</phase>
|
|
||||||
<goals>
|
|
||||||
<goal>check</goal>
|
|
||||||
</goals>
|
|
||||||
<configuration>
|
|
||||||
<ignoredResourcePatterns>
|
|
||||||
<ignoredResourcePattern>org/hornetq/utils.HornetQUtil(Bundle|Logger).i18n.properties</ignoredResourcePattern>
|
|
||||||
</ignoredResourcePatterns>
|
|
||||||
</configuration>
|
|
||||||
</execution>
|
|
||||||
</executions>
|
|
||||||
</plugin>
|
|
||||||
</plugins>
|
|
||||||
</build>
|
|
||||||
</project>
|
|
||||||
@ -1,47 +0,0 @@
|
|||||||
/*
|
|
||||||
* Copyright 2012-2016 the original author or authors.
|
|
||||||
*
|
|
||||||
* Licensed under the Apache License, Version 2.0 (the "License");
|
|
||||||
* you may not use this file except in compliance with the License.
|
|
||||||
* You may obtain a copy of the License at
|
|
||||||
*
|
|
||||||
* http://www.apache.org/licenses/LICENSE-2.0
|
|
||||||
*
|
|
||||||
* Unless required by applicable law or agreed to in writing, software
|
|
||||||
* distributed under the License is distributed on an "AS IS" BASIS,
|
|
||||||
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
||||||
* See the License for the specific language governing permissions and
|
|
||||||
* limitations under the License.
|
|
||||||
*/
|
|
||||||
|
|
||||||
package org.springframework.boot.starter.hornetq;
|
|
||||||
|
|
||||||
import javax.annotation.PostConstruct;
|
|
||||||
|
|
||||||
import org.apache.commons.logging.Log;
|
|
||||||
import org.apache.commons.logging.LogFactory;
|
|
||||||
|
|
||||||
import org.springframework.boot.autoconfigure.EnableAutoConfiguration;
|
|
||||||
import org.springframework.context.annotation.Configuration;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* {@link EnableAutoConfiguration Auto-configuration} to print a deprecation warning about
|
|
||||||
* the starter.
|
|
||||||
*
|
|
||||||
* @author Stephane Nicoll
|
|
||||||
* @since 1.4.0
|
|
||||||
*/
|
|
||||||
@Configuration
|
|
||||||
@Deprecated
|
|
||||||
public class HornetQStarterDeprecationWarningAutoConfiguration {
|
|
||||||
|
|
||||||
private static final Log logger = LogFactory
|
|
||||||
.getLog(HornetQStarterDeprecationWarningAutoConfiguration.class);
|
|
||||||
|
|
||||||
@PostConstruct
|
|
||||||
public void logWarning() {
|
|
||||||
logger.warn("spring-boot-starter-hornetq is deprecated as of Spring Boot 1.4, "
|
|
||||||
+ "please migrate to spring-boot-starter-artemis");
|
|
||||||
}
|
|
||||||
|
|
||||||
}
|
|
||||||
@ -1,3 +0,0 @@
|
|||||||
# Auto Configure
|
|
||||||
org.springframework.boot.autoconfigure.EnableAutoConfiguration=\
|
|
||||||
org.springframework.boot.starter.hornetq.HornetQStarterDeprecationWarningAutoConfiguration
|
|
||||||
@ -1 +0,0 @@
|
|||||||
provides: hornetq-jms-client,spring-jms
|
|
||||||
Loading…
Reference in New Issue