基于spring的jms施用学习笔记（2）-activemq

基于spring的jms应用学习笔记（2）--activemq

1.准备：

   activeMQ官方网站下载apache-activemq-5.1.0

2.spring-activeMQ.xml的配置文件如下：

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE beans PUBLIC "-//SPRING//DTD BEAN//EN" "http://www.springframework.org/dtd/spring-beans.dtd">

<beans>	
	<!--activeMQ connectionFactory-->
	<bean id="activeMQconnectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory">
		<property name="brokerURL" value="tcp://localhost:61616"></property>
	</bean>

	<!-- 声明ActiveMQ消息目标,目标可以是一个队列，也可以是一个主题ActiveMQTopic-->
	<bean id="activeMQdestination" class="org.apache.activemq.command.ActiveMQQueue">
		<constructor-arg index="0" value="cn.liye.queue"></constructor-arg><!--随便起-->
	</bean>

	<bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate102">
		<property name="connectionFactory" ref="activeMQconnectionFactory"></property>
		<property name="defaultDestination" ref="activeMQdestination"></property>
		<property name="receiveTimeout" value="6000"></property>
	</bean>


	<!-- 消息发布者 -->
	<bean id="msgProducer" class="com.liye.mars.jms.MessageProducer">
		<property name="jmsTemplate" ref="jmsTemplate" />
	</bean>
	<!-- 消息接收者 -->
	<bean id="msgConsumer" class="com.liye.mars.jms.MessageConsumer">
		<property name="jmsTemplate" ref="jmsTemplate" />
	</bean>
</beans>

 

其他代码详见http://cnhzliye.iteye.com/blog/373320

 

3.导入activemq-core-5.1.0.jar，geronimo-jms_1.1_spec-1.1.1.jar包

 

4.%ACTIVEMQ_HOME%\bin下启动activeMQ服务

   运行TestMsgConsumer，TestMsgProducer。