Activemq整合spring
2017-11-28 21:57
435 查看
整合步骤
第一步:引用相关的jar包。
第二步:配置Activemq整合spring。配置ConnectionFactory
配置消费者
第三步:配置生产者。
使用JMSTemplate对象。发送消息。
第四步:在spring容器中配置Destination。
第一步:引用相关的jar包。
第二步:配置Activemq整合spring。配置ConnectionFactory
配置消费者
<!-- 真正可以产生Connection的ConnectionFactory,由对应的 JMS服务厂商提供 --> <bean id="targetConnectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory"> <property name="brokerURL" value="tcp://192.168.150.128:61616" /> </bean> <!-- Spring用于管理真正的ConnectionFactory的ConnectionFactory --> <bean id="connectionFactory" class="org.springframework.jms.connection.SingleConnectionFactory"> <!-- 目标ConnectionFactory对应真实的可以产生JMS Connection的ConnectionFactory --> <property name="targetConnectionFactory" ref="targetConnectionFactory" /> </bean> <!--这个是队列目的地,点对点的 --> <bean id="queueDestination" class="org.apache.activemq.command.ActiveMQQueue"> <constructor-arg> <value>spring-queue</value> </constructor-arg> </bean> <!--这个是主题目的地,一对多的 --> <bean id="topicDestination" class="org.apache.activemq.command.ActiveMQTopic"> <constructor-arg value="itemAddTopic" /> </bean> <!-- 监听商品添加消息,同步索引库 --> <bean id="itemAddMessageListener" class="cn.e3mall.search.message.ItemAddMessageListener"/> <bean class="org.springframework.jms.listener.DefaultMessageListenerContainer"> <property name="connectionFactory" ref="connectionFactory" /> <property name="destination" ref="topicDestination" /> <property name="messageListener" ref="itemAddMessageListener" /> </bean>
第三步:配置生产者。
使用JMSTemplate对象。发送消息。
第四步:在spring容器中配置Destination。
<!-- 真正可以产生Connection的ConnectionFactory,由对应的 JMS服务厂商提供 --> <bean id="targetConnectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory"> <property name="brokerURL" value="tcp://192.168.150.128:61616" /> </bean> <!-- Spring用于管理真正的ConnectionFactory的ConnectionFactory --> <bean id="connectionFactory" class="org.springframework.jms.connection.SingleConnectionFactory"> <!-- 目标ConnectionFactory对应真实的可以产生JMS Connection的ConnectionFactory --> <property name="targetConnectionFactory" ref="targetConnectionFactory" /> </bean> <!-- 配置生产者 --> <!-- Spring提供的JMS工具类,它可以进行消息发送、接收等 --> <bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate"> <!-- 这个connectionFactory对应的是我们定义的Spring提供的那个ConnectionFactory对象 --> <property name="connectionFactory" ref="connectionFactory" /> </bean> <!--这个是队列目的地,点对点的 --> <bean id="queueDestination" class="org.apache.activemq.command.ActiveMQQueue"> <constructor-arg> <value>spring-queue</value> </constructor-arg> </bean> <!--这个是主题目的地,一对多的 --> <bean id="topicDestination" class="org.apache.activemq.command.ActiveMQTopic"> <constructor-arg value="itemAddTopic" /> </bean>
相关文章推荐
- ActiveMQ与Spring的整合之异步发送电子邮件
- spring activeMQ 整合(四): JMS 事务管理
- (八)Spring Boot整合ActiveMQ
- 深入浅出JMS(四)--Spring和ActiveMQ整合的完整实例
- 11.(此处为以上综合精华)如何使用ActiveMQ,以及spring+jms下整合
- Java消息队列-Spring整合ActiveMq
- 消息队列activemq整合spring发送端和接收端配置
- activeMq 消费者整合spring
- Spring整合ActiveMQ
- spring整合ActiveMQ
- Spring整合JMS(一)——基于ActiveMQ实现
- ActiveMQ入门教程(五) - ActiveMQ与Spring整合
- JMS之——Spring与ActiveMQ整合案例
- Spring整合JMS(一)——基于ActiveMQ实现
- Spring学习笔记 - Spring 整合 JMS - ActiveMQ
- ActiveMQ的入门案例以及整合Spring的简单使用
- Spring整合JMS(一)——基于ActiveMQ实现
- 深入浅出JMS(四)--Spring和ActiveMQ整合的完整实例
- Spring Boot与ActiveMQ整合
- Springboot整合ActiveMQ