SkyID
/
zheng
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

修正MQListener类

This commit is contained in:
shuzheng 2017-02-07 10:51:42 +08:00
parent 11df918bb5
commit a92ee4c0ca
6 changed files with 12 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
zheng-cms/zheng-cms-admin/src/main/java/com/zheng/cms/admin/jms/defaultQueueMessageListener.java → zheng-cms/zheng-cms-admin/src/main/java/com/zheng/cms/admin/jms/DefaultMessageQueueListener.java
View File

@ -14,9 +14,9 @@ import javax.jms.TextMessage;
* MQ消费者
* Created by ZhangShuzheng on 2017/01/12.
*/
public class DefaultQueueMessageListener implements MessageListener {
public class DefaultMessageQueueListener implements MessageListener {
private static Logger _log = LoggerFactory.getLogger(DefaultQueueMessageListener.class);
private static Logger _log = LoggerFactory.getLogger(DefaultMessageQueueListener.class);
@Autowired
ThreadPoolTaskExecutor threadPoolTaskExecutor;

4
zheng-cms/zheng-cms-admin/src/main/resources/applicationContext-activemq.xml
View File

@ -41,11 +41,11 @@
</bean>
<!-- 消费者 -->
<bean id="defaultQueueMessageListener" class="com.zheng.cms.admin.jms.DefaultQueueMessageListener"/>
<bean id="defaultMessageQueueListener" class="com.zheng.cms.admin.jms.DefaultMessageQueueListener"/>
<bean id="jmsContainer" class="org.springframework.jms.listener.DefaultMessageListenerContainer">
<property name="connectionFactory" ref="connectionFactory"/>
<property name="destination" ref="defaultQueueDestination"/>
<property name="messageListener" ref="defaultQueueMessageListener"/>
<property name="messageListener" ref="defaultMessageQueueListener"/>
<property name="sessionTransacted" value="true"/>
<!--<property name="concurrency" value="4-10"/>-->
</bean>

4
zheng-cms/zheng-cms-job/src/main/java/com/zheng/cms/job/jms/defaultQueueMessageListener.java → zheng-cms/zheng-cms-job/src/main/java/com/zheng/cms/job/jms/DefaultMessageQueueListener.java
View File

@ -18,9 +18,9 @@ import java.util.Date;
* MQ消费者
* Created by ZhangShuzheng on 2016/11/24.
*/
public class DefaultQueueMessageListener implements MessageListener {
public class DefaultMessageQueueListener implements MessageListener {
private static Logger _log = LoggerFactory.getLogger(DefaultQueueMessageListener.class);
private static Logger _log = LoggerFactory.getLogger(DefaultMessageQueueListener.class);
@Autowired
ThreadPoolTaskExecutor threadPoolTaskExecutor;

4
zheng-cms/zheng-cms-job/src/main/resources/applicationContext-activemq.xml
View File

@ -23,11 +23,11 @@
</bean>
<!-- 消费者 -->
<bean id="defaultQueueMessageListener" class="com.zheng.cms.job.jms.DefaultQueueMessageListener"/>
<bean id="defaultMessageQueueListener" class="com.zheng.cms.job.jms.DefaultMessageQueueListener"/>
<bean id="jmsContainer" class="org.springframework.jms.listener.DefaultMessageListenerContainer">
<property name="connectionFactory" ref="connectionFactory"/>
<property name="destination" ref="defaultQueueDestination"/>
<property name="messageListener" ref="defaultQueueMessageListener"/>
<property name="messageListener" ref="defaultMessageQueueListener"/>
<property name="sessionTransacted" value="true"/>
<!--<property name="concurrency" value="4-10"/>-->
</bean>

4
zheng-cms/zheng-cms-web/src/main/java/com/zheng/cms/web/jms/defaultQueueMessageListener.java → zheng-cms/zheng-cms-web/src/main/java/com/zheng/cms/web/jms/DefaultMessageQueueListener.java
View File

@ -18,9 +18,9 @@ import java.util.Date;
* MQ消费者
* Created by ZhangShuzheng on 2016/11/24.
*/
public class DefaultQueueMessageListener implements MessageListener {
public class DefaultMessageQueueListener implements MessageListener {
private static Logger _log = LoggerFactory.getLogger(DefaultQueueMessageListener.class);
private static Logger _log = LoggerFactory.getLogger(DefaultMessageQueueListener.class);
@Autowired
ThreadPoolTaskExecutor threadPoolTaskExecutor;

4
zheng-cms/zheng-cms-web/src/main/resources/applicationContext-activemq.xml
View File

@ -41,11 +41,11 @@
</bean>
<!-- 消费者 -->
<bean id="defaultQueueMessageListener" class="com.zheng.cms.web.jms.DefaultQueueMessageListener"/>
<bean id="defaultMessageQueueListener" class="com.zheng.cms.web.jms.DefaultMessageQueueListener"/>
<bean id="jmsContainer" class="org.springframework.jms.listener.DefaultMessageListenerContainer">
<property name="connectionFactory" ref="connectionFactory"/>
<property name="destination" ref="defaultQueueDestination"/>
<property name="messageListener" ref="defaultQueueMessageListener"/>
<property name="messageListener" ref="defaultMessageQueueListener"/>
<property name="sessionTransacted" value="true"/>
<!--<property name="concurrency" value="4-10"/>-->
</bean>