Selaa lähdekoodia

注释activemq

shuzheng 9 vuotta sitten
vanhempi
sitoutus
0ba10eeea8

+ 14 - 20
cms/cms-web/src/main/java/com/zheng/cms/controller/ActiveMQController.java

@@ -1,15 +1,9 @@
 package com.zheng.cms.controller;
 package com.zheng.cms.controller;
 
 
-import com.zheng.common.util.JmsUtil;
 import org.slf4j.Logger;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.slf4j.LoggerFactory;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.jms.core.JmsTemplate;
 import org.springframework.stereotype.Controller;
 import org.springframework.stereotype.Controller;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.ResponseBody;
-
-import javax.jms.Destination;
 
 
 /**
 /**
  * 消息队列controller
  * 消息队列controller
@@ -22,19 +16,19 @@ public class ActiveMQController extends BaseController {
 
 
 	private static Logger _log = LoggerFactory.getLogger(ActiveMQController.class);
 	private static Logger _log = LoggerFactory.getLogger(ActiveMQController.class);
 
 
-	@Autowired
-	JmsTemplate jmsTemplate;
-
-	@Autowired
-	Destination defaultQueueDestination;
-
-	@RequestMapping("/send")
-	@ResponseBody
-	public Object send() {
-		for (int i = 0; i < 1000; i ++) {
-			JmsUtil.sendMessage(jmsTemplate, defaultQueueDestination, "消息" + i);
-		}
-		return "success";
-	}
+//	@Autowired
+//	JmsTemplate jmsTemplate;
+//
+//	@Autowired
+//	Destination defaultQueueDestination;
+//
+//	@RequestMapping("/send")
+//	@ResponseBody
+//	public Object send() {
+//		for (int i = 0; i < 1000; i ++) {
+//			JmsUtil.sendMessage(jmsTemplate, defaultQueueDestination, "消息" + i);
+//		}
+//		return "success";
+//	}
 
 
 }
 }

+ 33 - 32
cms/cms-web/src/main/resources/applicationContext-activemq.xml

@@ -5,37 +5,38 @@
 		http://www.springframework.org/schema/beans/spring-beans-3.2.xsd"
 		http://www.springframework.org/schema/beans/spring-beans-3.2.xsd"
 	   default-autowire="byName">
 	   default-autowire="byName">
 
 
-	<!-- 连接工厂 -->
-	<bean id="activeMqConnectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory">
-		<property name="brokerURL" value="${AvtiveMQ.brokerURL}"/>
-	</bean>
-	<bean id="pooledConnectionFactory" class="org.apache.activemq.pool.PooledConnectionFactory">
-		<property name="connectionFactory" ref="activeMqConnectionFactory"/>
-		<property name="maxConnections" value="10"/>
-	</bean>
-	<bean id="connectionFactory" class="org.springframework.jms.connection.SingleConnectionFactory">
-		<property name="targetConnectionFactory" ref="pooledConnectionFactory"/>
-	</bean>
-	<!-- 点对点队列 -->
-	<bean id="defaultQueueDestination" class="org.apache.activemq.command.ActiveMQQueue">
-		<constructor-arg index="0" value="com.zheng.cms.queue.default" />
-	</bean>
-	<!-- 一对多队列 -->
-	<!--
-	<bean id="defaultTopicDestination" class="org.apache.activemq.command.ActiveMQTopic">
-		<constructor-arg index="0" value="com.zheng.cms.topic.default" />
-	</bean>
-	-->
+	<!--&lt;!&ndash; 连接工厂 &ndash;&gt;-->
+	<!--<bean id="activeMqConnectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory">-->
+		<!--<property name="brokerURL" value="${AvtiveMQ.brokerURL}"/>-->
+	<!--</bean>-->
+	<!--<bean id="pooledConnectionFactory" class="org.apache.activemq.pool.PooledConnectionFactory">-->
+		<!--<property name="connectionFactory" ref="activeMqConnectionFactory"/>-->
+		<!--<property name="maxConnections" value="10"/>-->
+	<!--</bean>-->
+	<!--<bean id="connectionFactory" class="org.springframework.jms.connection.SingleConnectionFactory">-->
+		<!--<property name="targetConnectionFactory" ref="pooledConnectionFactory"/>-->
+	<!--</bean>-->
+	<!--&lt;!&ndash; 点对点队列 &ndash;&gt;-->
+	<!--<bean id="defaultQueueDestination" class="org.apache.activemq.command.ActiveMQQueue">-->
+		<!--<constructor-arg index="0" value="com.zheng.cms.queue.default" />-->
+	<!--</bean>-->
+	<!--&lt;!&ndash; 一对多队列 &ndash;&gt;-->
+	<!--&lt;!&ndash;-->
+	<!--<bean id="defaultTopicDestination" class="org.apache.activemq.command.ActiveMQTopic">-->
+		<!--<constructor-arg index="0" value="com.zheng.cms.topic.default" />-->
+	<!--</bean>-->
+	<!--&ndash;&gt;-->
+
+	<!--&lt;!&ndash; 生产者 &ndash;&gt;-->
+	<!--<bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate">-->
+		<!--<property name="connectionFactory" ref="connectionFactory"/>-->
+	<!--</bean>-->
+	<!--&lt;!&ndash; 消费者 &ndash;&gt;-->
+	<!--<bean id="defaultQueueMessageListener" class="com.zheng.cms.jms.defaultQueueMessageListener"/>-->
+	<!--<bean id="jmsContainer"  class="org.springframework.jms.listener.DefaultMessageListenerContainer">-->
+		<!--<property name="connectionFactory" ref="connectionFactory" />-->
+		<!--<property name="destination" ref="defaultQueueDestination" />-->
+		<!--<property name="messageListener" ref="defaultQueueMessageListener" />-->
+	<!--</bean>-->
 
 
-	<!-- 生产者 -->
-	<bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate">
-		<property name="connectionFactory" ref="connectionFactory"/>
-	</bean>
-	<!-- 消费者 -->
-	<bean id="defaultQueueMessageListener" class="com.zheng.cms.jms.defaultQueueMessageListener"/>
-	<bean id="jmsContainer"  class="org.springframework.jms.listener.DefaultMessageListenerContainer">
-		<property name="connectionFactory" ref="connectionFactory" />
-		<property name="destination" ref="defaultQueueDestination" />
-		<property name="messageListener" ref="defaultQueueMessageListener" />
-	</bean>
 </beans>
 </beans>

+ 1 - 1
cms/cms-web/src/main/resources/profiles/dev.properties

@@ -1,3 +1,3 @@
 profile.env=dev
 profile.env=dev
-### activeMq的broker地址
+### activeMq
 AvtiveMQ.brokerURL=failover:(tcp://127.0.0.1:61616?wireFormat.maxInactivityDuration=0)
 AvtiveMQ.brokerURL=failover:(tcp://127.0.0.1:61616?wireFormat.maxInactivityDuration=0)

+ 1 - 1
cms/cms-web/src/main/resources/profiles/prod.properties

@@ -1,3 +1,3 @@
 profile.env=prod
 profile.env=prod
-### activeMq的broker地址
+### activeMq
 AvtiveMQ.brokerURL=failover:(tcp://127.0.0.1:61616?wireFormat.maxInactivityDuration=0)
 AvtiveMQ.brokerURL=failover:(tcp://127.0.0.1:61616?wireFormat.maxInactivityDuration=0)

+ 1 - 1
cms/cms-web/src/main/resources/profiles/test.properties

@@ -1,3 +1,3 @@
 profile.env=test
 profile.env=test
-### activeMq的broker地址
+### activeMq
 AvtiveMQ.brokerURL=failover:(tcp://127.0.0.1:61616?wireFormat.maxInactivityDuration=0)
 AvtiveMQ.brokerURL=failover:(tcp://127.0.0.1:61616?wireFormat.maxInactivityDuration=0)