package com.java110.order.mq;
|
|
import org.apache.activemq.ActiveMQConnectionFactory;
|
import org.apache.activemq.pool.PooledConnectionFactory;
|
import org.apache.commons.lang.math.NumberUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.beans.factory.annotation.Value;
|
import org.springframework.boot.context.properties.ConfigurationProperties;
|
import org.springframework.context.annotation.Bean;
|
import org.springframework.jms.core.JmsTemplate;
|
|
import javax.jms.ConnectionFactory;
|
|
/**
|
* Created by wuxw on 2017/4/17.
|
*/
|
@ConfigurationProperties(prefix = "mq.queue.name",locations="classpath:mq/mq.properties")
|
public class MqConfig {
|
|
@Autowired
|
ConnectionFactory mqConnectionFactory;
|
|
@Autowired
|
PooledConnectionFactory pooledConnectionFactory;
|
|
@Value("user")
|
private String userQueueName;
|
|
@Value("deleteOrderQueue")
|
private String deleteOrderQueueName;
|
@Value("deleteOrderTopic")
|
private String deleteOrderTopicName;
|
|
private String brokerUrl;
|
|
private String username;
|
|
private String password;
|
|
private String maxConnection;
|
|
/**
|
* 默认最大链接数
|
*/
|
private final static int DEFAULT_MAX_CONNECTION = 50;
|
|
|
/**
|
* activemq 链接工厂
|
* 真正可以产生Connection的ConnectionFactory，由对应的 JMS服务厂商提供
|
* @return
|
*/
|
@Bean(name="mqConnectionFactory")
|
public ConnectionFactory mqConnectionFactory(){
|
ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory();
|
connectionFactory.setBrokerURL(brokerUrl);
|
connectionFactory.setUserName(username);
|
connectionFactory.setPassword(password);
|
return connectionFactory;
|
}
|
|
/**
|
* 池链接
|
* ActiveMQ为我们提供了一个PooledConnectionFactory，通过往里面注入一个ActiveMQConnectionFactory
|
可以用来将Connection、Session和MessageProducer池化，这样可以大大的减少我们的资源消耗。 要依赖于 activemq-pool包
|
* @return
|
*/
|
@Bean(name="pooledConnectionFactory")
|
public PooledConnectionFactory pooledConnectionFactory(){
|
|
PooledConnectionFactory connectionFactory = new PooledConnectionFactory();
|
connectionFactory.setConnectionFactory(mqConnectionFactory);
|
connectionFactory.setMaxConnections(NumberUtils.isNumber(maxConnection)?NumberUtils.toInt(maxConnection):DEFAULT_MAX_CONNECTION);
|
return connectionFactory;
|
}
|
|
@Bean(name="deleteOrderQueueJmsTemplate")
|
public JmsTemplate deleteOrderQueueJmsTemplate(){
|
JmsTemplate jmsTemplate = new JmsTemplate();
|
jmsTemplate.setConnectionFactory(pooledConnectionFactory);
|
jmsTemplate.setDefaultDestinationName(deleteOrderQueueName);
|
return jmsTemplate;
|
}
|
public String getUserQueueName() {
|
return userQueueName;
|
}
|
|
public void setUserQueueName(String userQueueName) {
|
this.userQueueName = userQueueName;
|
}
|
|
public String getDeleteOrderQueueName() {
|
return deleteOrderQueueName;
|
}
|
|
public void setDeleteOrderQueueName(String deleteOrderQueueName) {
|
this.deleteOrderQueueName = deleteOrderQueueName;
|
}
|
|
public String getDeleteOrderTopicName() {
|
return deleteOrderTopicName;
|
}
|
|
public void setDeleteOrderTopicName(String deleteOrderTopicName) {
|
this.deleteOrderTopicName = deleteOrderTopicName;
|
}
|
|
public String getUsername() {
|
return username;
|
}
|
|
public void setUsername(String username) {
|
this.username = username;
|
}
|
|
public String getPassword() {
|
return password;
|
}
|
|
public void setPassword(String password) {
|
this.password = password;
|
}
|
|
public String getBrokerUrl() {
|
return brokerUrl;
|
}
|
|
public void setBrokerUrl(String brokerUrl) {
|
this.brokerUrl = brokerUrl;
|
}
|
|
public ConnectionFactory getMqConnectionFactory() {
|
return mqConnectionFactory;
|
}
|
|
public void setMqConnectionFactory(ConnectionFactory mqConnectionFactory) {
|
this.mqConnectionFactory = mqConnectionFactory;
|
}
|
|
public String getMaxConnection() {
|
return maxConnection;
|
}
|
|
public void setMaxConnection(String maxConnection) {
|
this.maxConnection = maxConnection;
|
}
|
|
public PooledConnectionFactory getPooledConnectionFactory() {
|
return pooledConnectionFactory;
|
}
|
|
public void setPooledConnectionFactory(PooledConnectionFactory pooledConnectionFactory) {
|
this.pooledConnectionFactory = pooledConnectionFactory;
|
}
|
}
|
