Question

activemq用spring怎么配置messageconsumer

Answer 1

首先，如果知道了activemq的工作原理，以及spring是如何来调用activemq，估计你就知道怎么配置了，这里我先说一下，amq的工作原理和spring在调用amq时的工作流程，然后再给出配置文件，相信你会更加明白。

工作的时候，部署结构如下（图有点大，使用右键->在新标签页打开）：

针对上面的produce message，详细的过程如下(图有点大，使用右键->在新标签页打开)：

针对consume message，详细过程如下：

spring的配置文件其实，很简单：

生产：

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="

	xmlns:xsi="

	xsi:schemaLocation="


	<bean id="connf" class="org.apache.activemq.ActiveMQConnectionFactory">
		<property name="brokerURL" value="tcp://localhost:61616"></property>
	</bean>

	<bean id="mydest" class="org.apache.activemq.command.ActiveMQQueue">
		<constructor-arg index="0" value="test.queue"></constructor-arg>
	</bean>
	
	<bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate">
		<property name="connectionFactory" ref="connf"></property>
	</bean>
</beans>

消费：

<?xml version="1.0" encoding="UTF-8"?>

<beans xmlns="

	xmlns:xsi="

	xsi:schemaLocation="


	<bean id="connf" class="org.apache.activemq.ActiveMQConnectionFactory">
		<property name="brokerURL" value="tcp://localhost:61616"></property>
	</bean>

	<bean id="mydest" class="org.apache.activemq.command.ActiveMQQueue">
		<constructor-arg index="0" value="test.queue"></constructor-arg>
	</bean>
	
	<bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate">
		<property name="connectionFactory" ref="connf"></property>
		<property name="defaultDestination" ref="mydest"></property>
	</bean>
	
</beans>