@Configuration
public class?ActiveMQConfig {

??? @Value(“${spring.activemq.broker-url:disabled}”)
??? String?brokerURL?;

??? @Value(“${activemq.listener.enable:disabled}”)
??? String?listenerEnable;

??? @Bean
????public????ActiveMQUtil?? getActiveMQUtil()?throws?JMSException {
????????if(brokerURL.equals(“disabled”)){
????????????return null;
??????? }
??????? ActiveMQUtil activeMQUtil=new?ActiveMQUtil();
??????? activeMQUtil.init(brokerURL);
????????return??activeMQUtil;
? ??}

????//定义一个消息监听器连接工厂，这里定义的是点对点模式的监听器连接工厂
????@Bean(name =?“jmsQueueListener”)
????public?DefaultJmsListenerContainerFactory jmsQueueListenerContainerFactory(ActiveMQConnectionFactory activeMQConnectionFactory ) {
??????? DefaultJmsListenerContainerFactory factory =?new?DefaultJmsListenerContainerFactory();
????????if(!listenerEnable.equals(“true”)){
????????????return null;
??????? }

??????? factory.setConnectionFactory(activeMQConnectionFactory);
????????//设置并发数
????????factory.setConcurrency(“5”);

????????//重连间隔时间
?????? factory.setRecoveryInterval(5000L);
?????? factory.setSessionTransacted(false);
?????? factory.setSessionAcknowledgeMode(Session.CLIENT_ACKNOWLEDGE);

????????return?factory;
??? }

??? @Bean
????public?ActiveMQConnectionFactory activeMQConnectionFactory ( ){

????????ActiveMQConnectionFactory activeMQConnectionFactory =
????????????????new?ActiveMQConnectionFactory(??brokerURL);
????????return?activeMQConnectionFactory;
??? }

}

public class?ActiveMQUtil {
??? PooledConnectionFactory?pooledConnectionFactory=null;

????public?ConnectionFactory init(String brokerUrl) {

??????? ActiveMQConnectionFactory factory =?new?ActiveMQConnectionFactory(brokerUrl);
?????????//加入连接池
????????pooledConnectionFactory=new?PooledConnectionFactory(factory);
????????//出现异常时重新连接
????????pooledConnectionFactory.setReconnectOnException(true);
????????//
????????pooledConnectionFactory.setMaxConnections(5);
????????pooledConnectionFactory.setExpiryTimeout(10000);
???? ???return pooledConnectionFactory;
??? }

????public?ConnectionFactory getConnectionFactory(){
????????return pooledConnectionFactory;
??? }
}

?