优化配置

This commit is contained in:
shuzheng 2017-04-05 23:37:01 +08:00
parent b92c6c0976
commit 0e13bde325
1 changed files with 39 additions and 45 deletions

View File

@ -1,53 +1,47 @@
<?xml version="1.0" encoding="UTF-8"?> <?xml version="1.0" encoding="UTF-8"?>
<!-- 查找最新的schemaLocation 访问 http://www.springframework.org/schema/ --> <!-- 查找最新的schemaLocation 访问 http://www.springframework.org/schema/ -->
<beans xmlns="http://www.springframework.org/schema/beans" xmlns:context="http://www.springframework.org/schema/context" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:amq="http://activemq.apache.org/schema/core" <beans xmlns="http://www.springframework.org/schema/beans"
xmlns:jms="http://www.springframework.org/schema/jms" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://www.springframework.org/schema/beans xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans-3.2.xsd http://www.springframework.org/schema/beans/spring-beans-3.2.xsd">
http://www.springframework.org/schema/context
http://www.springframework.org/schema/context/spring-context-3.2.xsd
http://www.springframework.org/schema/jms
http://www.springframework.org/schema/jms/spring-jms-4.1.xsd
http://activemq.apache.org/schema/core
http://activemq.apache.org/schema/core/activemq-core-5.8.0.xsd">
<!-- 连接工厂 --> <!-- 连接工厂 -->
<bean id="activeMqConnectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory"> <bean id="activeMqConnectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory">
<property name="brokerURL" value="${AvtiveMQ.brokerURL}"/> <property name="brokerURL" value="${AvtiveMQ.brokerURL}"/>
<property name="useAsyncSend" value="true"/> <property name="useAsyncSend" value="true"/>
</bean> </bean>
<bean id="connectionFactory" class="org.springframework.jms.connection.CachingConnectionFactory"> <bean id="connectionFactory" class="org.springframework.jms.connection.CachingConnectionFactory">
<property name="targetConnectionFactory" ref="activeMqConnectionFactory"/> <property name="targetConnectionFactory" ref="activeMqConnectionFactory"/>
<property name="sessionCacheSize" value="100"/> <property name="sessionCacheSize" value="100"/>
</bean> </bean>
<!-- 点对点队列 --> <!-- 点对点队列 -->
<bean id="defaultQueueDestination" class="org.apache.activemq.command.ActiveMQQueue"> <bean id="defaultQueueDestination" class="org.apache.activemq.command.ActiveMQQueue">
<constructor-arg index="0" value="com.zheng.cms.queue.default"/> <constructor-arg index="0" value="com.zheng.cms.queue.default"/>
</bean> </bean>
<!-- 一对多队列 --> <!-- 一对多队列 -->
<bean id="defaultTopicDestination" class="org.apache.activemq.command.ActiveMQTopic"> <bean id="defaultTopicDestination" class="org.apache.activemq.command.ActiveMQTopic">
<constructor-arg index="0" value="com.zheng.cms.topic.default"/> <constructor-arg index="0" value="com.zheng.cms.topic.default"/>
</bean> </bean>
<!-- 生产者 --> <!-- 生产者 -->
<bean id="jmsQueueTemplate" class="org.springframework.jms.core.JmsTemplate"> <bean id="jmsQueueTemplate" class="org.springframework.jms.core.JmsTemplate">
<property name="connectionFactory" ref="connectionFactory"/> <property name="connectionFactory" ref="connectionFactory"/>
<property name="pubSubDomain" value="false" /> <property name="pubSubDomain" value="false"/>
</bean> </bean>
<bean id="jmsTopicTemplate" class="org.springframework.jms.core.JmsTemplate"> <bean id="jmsTopicTemplate" class="org.springframework.jms.core.JmsTemplate">
<property name="connectionFactory" ref="connectionFactory"/> <property name="connectionFactory" ref="connectionFactory"/>
<property name="pubSubDomain" value="true" /> <property name="pubSubDomain" value="true"/>
</bean> </bean>
<!-- 消费者 --> <!-- 消费者 -->
<bean id="defaultMessageQueueListener" class="com.zheng.cms.web.jms.DefaultMessageQueueListener"/> <bean id="defaultMessageQueueListener" class="com.zheng.cms.web.jms.DefaultMessageQueueListener"/>
<bean id="jmsContainer" class="org.springframework.jms.listener.DefaultMessageListenerContainer"> <bean id="jmsContainer" class="org.springframework.jms.listener.DefaultMessageListenerContainer">
<property name="connectionFactory" ref="connectionFactory"/> <property name="connectionFactory" ref="connectionFactory"/>
<property name="destination" ref="defaultQueueDestination"/> <property name="destination" ref="defaultQueueDestination"/>
<property name="messageListener" ref="defaultMessageQueueListener"/> <property name="messageListener" ref="defaultMessageQueueListener"/>
<property name="sessionTransacted" value="true"/> <property name="sessionTransacted" value="true"/>
<!--<property name="concurrency" value="4-10"/>--> <!--<property name="concurrency" value="4-10"/>-->
</bean> </bean>
</beans> </beans>