shuzheng 9 жил өмнө
parent
commit
32145318ac

+ 2 - 6
zheng-cms/zheng-cms-admin/src/main/java/com/zheng/cms/admin/jms/defaultQueueMessageListener.java

@@ -1,8 +1,6 @@
 package com.zheng.cms.admin.jms;
 
-import com.zheng.cms.dao.model.CmsUser;
 import com.zheng.cms.rpc.api.UserService;
-import net.sf.json.JSONObject;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -11,16 +9,14 @@ import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
 import javax.jms.Message;
 import javax.jms.MessageListener;
 import javax.jms.TextMessage;
-import java.text.SimpleDateFormat;
-import java.util.Date;
 
 /**
  * MQ消费者
  * Created by ZhangShuzheng on 2017/01/12.
  */
-public class defaultQueueMessageListener implements MessageListener {
+public class DefaultQueueMessageListener implements MessageListener {
 
-	private static Logger _log = LoggerFactory.getLogger(defaultQueueMessageListener.class);
+	private static Logger _log = LoggerFactory.getLogger(DefaultQueueMessageListener.class);
 
 	@Autowired
 	ThreadPoolTaskExecutor threadPoolTaskExecutor;

+ 1 - 1
zheng-cms/zheng-cms-admin/src/main/resources/applicationContext-activemq.xml

@@ -41,7 +41,7 @@
 	</bean>
 
 	<!-- 消费者 -->
-	<bean id="defaultQueueMessageListener" class="com.zheng.cms.admin.jms.defaultQueueMessageListener"/>
+	<bean id="defaultQueueMessageListener" class="com.zheng.cms.admin.jms.DefaultQueueMessageListener"/>
 	<bean id="jmsContainer" class="org.springframework.jms.listener.DefaultMessageListenerContainer">
 		<property name="connectionFactory" ref="connectionFactory"/>
 		<property name="destination" ref="defaultQueueDestination"/>

+ 2 - 2
zheng-cms/zheng-cms-job/src/main/java/com/zheng/cms/job/jms/defaultQueueMessageListener.java

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

+ 1 - 1
zheng-cms/zheng-cms-job/src/main/resources/applicationContext-activemq.xml

@@ -23,7 +23,7 @@
 	</bean>
 
 	<!-- 消费者 -->
-	<bean id="defaultQueueMessageListener" class="com.zheng.cms.job.jms.defaultQueueMessageListener"/>
+	<bean id="defaultQueueMessageListener" class="com.zheng.cms.job.jms.DefaultQueueMessageListener"/>
 	<bean id="jmsContainer"  class="org.springframework.jms.listener.DefaultMessageListenerContainer">
 		<property name="connectionFactory" ref="connectionFactory"/>
 		<property name="destination" ref="defaultQueueDestination"/>

+ 2 - 2
zheng-cms/zheng-cms-web/src/main/java/com/zheng/cms/web/jms/defaultQueueMessageListener.java

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

+ 1 - 1
zheng-cms/zheng-cms-web/src/main/resources/applicationContext-activemq.xml

@@ -41,7 +41,7 @@
 	</bean>
 
 	<!-- 消费者 -->
-	<bean id="defaultQueueMessageListener" class="com.zheng.cms.web.jms.defaultQueueMessageListener"/>
+	<bean id="defaultQueueMessageListener" class="com.zheng.cms.web.jms.DefaultQueueMessageListener"/>
 	<bean id="jmsContainer" class="org.springframework.jms.listener.DefaultMessageListenerContainer">
 		<property name="connectionFactory" ref="connectionFactory"/>
 		<property name="destination" ref="defaultQueueDestination"/>