activemq消息发送和监听

package com.fw.demo.activemq.consumemq.config; import javax.jms.ConnectionFactory; import org.springframework.boot.autoconfigure.jms.DefaultJmsListenerContainerFactoryConfigurer; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import org.springframework.jms.annotation.EnableJms; import org.springframework.jms.config.DefaultJmsListenerContainerFactory; import org.springframework.jms.config.JmsListenerContainerFactory; /** * ClassName:MessageConfig <br/> * Function: TODO ADD FUNCTION. <br/> * Date: 2018年3月1日 上午11:16:34 <br/> * * @author tengdayong */ @EnableJms @Configuration public class JmsListenerConfig { /* @SuppressWarnings("rawtypes") @Bean("jmsTopicListenerContainerFactory") public JmsListenerContainerFactory jmsTopicListenerContainerFactory(ConnectionFactory connectionFactory) { DefaultJmsListenerContainerFactory factory = new DefaultJmsListenerContainerFactory(); factory.setConnectionFactory(connectionFactory); //重连间隔时间 //factory.setRecoveryInterval(1000L); factory.setPubSubDomain(true); // 给订阅者一个名字,并开启持久订阅 factory.setClientId("activemq-consume"); factory.setSubscriptionDurable(true); return factory; }*/ //监听queue消息 @SuppressWarnings("rawtypes") @Bean("jmsQueueListenerContainerFactory") public JmsListenerContainerFactory jmsQueueListenerContainerFactory(ConnectionFactory connectionFactory) { DefaultJmsListenerContainerFactory factory = new DefaultJmsListenerContainerFactory(); factory.setConnectionFactory(connectionFactory); //设置连接数 factory.setConcurrency("3-10"); //重连间隔时间 factory.setRecoveryInterval(1000L); factory.setPubSubDomain(false); return factory; } //订阅topic消息 @SuppressWarnings("rawtypes") @Bean("jmsTopicListenerContainerFactory") public JmsListenerContainerFactory jmsTopicListenerContainerFactory(ConnectionFactory connectionFactory) { DefaultJmsListenerContainerFactory factory = new DefaultJmsListenerContainerFactory(); factory.setConnectionFactory(connectionFactory); factory.setPubSubDomain(true); return factory; } //以下是持久订阅topic private JmsListenerContainerFactory<?> createDurableTopicJmsListenerContainerFactory(ConnectionFactory connectionFactory, DefaultJmsListenerContainerFactoryConfigurer configurer,String clientId){ DefaultJmsListenerContainerFactory factory = new DefaultJmsListenerContainerFactory(); configurer.configure(factory, connectionFactory); //重连间隔时间 factory.setRecoveryInterval(1000L); factory.setPubSubDomain(true); // 给订阅者一个名字,并开启持久订阅 factory.setClientId(clientId); factory.setSubscriptionDurable(true); return factory; } @Bean(name = "topicDataTopicListenerCF") public JmsListenerContainerFactory<?> bloodPressureTopicListenerCF(ConnectionFactory connectionFactory, DefaultJmsListenerContainerFactoryConfigurer configurer) { return createDurableTopicJmsListenerContainerFactory(connectionFactory,configurer,"topictest-topicData"); } }