博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
spring中配置监听队列的MQ
阅读量:6263 次
发布时间:2019-06-22

本文共 2343 字,大约阅读时间需要 7 分钟。

一、spring中配置监听队列的MQ相关信息
注:${}是读取propertites文件的常量,这里忽略。绿色部分配置在接收和发送端都要配置。
 
<bean id="axx" class="com.ibm.mq.jms.MQQueueConnectionFactory">
  <property name="hostName" value="${}" />
  <property name="port" value="${}" />
  <property name="queueManager" value="${}" />
  <property name="channel" value="${}" />
  <property name="CCSID" value="${}" />
  <property name="transportType" value="1"/>
 </bean>
 <bean id="bxx"
  class="org.springframework.jms.connection.UserCredentialsConnectionFactoryAdapter">
  <property name="targetConnectionFactory" ref="axx" />
 </bean>
  
 <!-- 定义一个队列,因为mq中消息有queue和topic的区别 -->
 <bean id="qxx" class="com.ibm.mq.jms.MQQueue">
   <constructor-arg index="0" value="${mq.queueManager}" />
   <constructor-arg index="1" value="${mq.corp.rev.queue}" />
 </bean>
<!-- 定义监听队列的容器,注意容器下包含的属性变量,至少要有前三个-->
 <bean id="
lxx"
  class="
org.springframework.jms.listener.DefaultMessageListenerContainer"
  lazy-init="false">
  <property name="
connectionFactory" ref="
bxx" />
  <property name="
destination" ref="
qxx" />
  <property name="
messageListener" ref="
testListener" />
  <property name="
sessionTransacted" value="true"/> 
 
 </bean>
     
<!-- 定义队列使用的监听器类,有三种,这里不想说了。这个类配置在监听容器里了,一直监听队列,对消息进行处理->       
 <bean id="
testListener" class="某个实现了jmsListener的
实现类,如继承了MessageListener" />
一、spring中配置发送消息的jmsTemplete的MQ相关信息
<bean id="axx" class="
com.ibm.mq.jms.MQQueueConnectionFactory
">
  <property name="hostName" value="${}" />
  <property name="port" value="${}" />
  <property name="queueManager" value="${}" />
  <property name="channel" value="${}" />
  <property name="CCSID" value="${}" />
  <property name="transportType" value="1"/>
 </bean>
 <bean id="bxx"
  class="org.springframework.jms.connection.UserCredentialsConnectionFactoryAdapter">
  <property name="targetConnectionFactory" ref="axx" />
 </bean>
  
 <!-- 定义一个队列,因为mq中消息有queue和topic的区别 -->
 <bean id="qxx" class="com.ibm.mq.jms.MQQueue">
   <constructor-arg index="0" value="${mq.queueManager}" />
   <constructor-arg index="1" value="${mq.corp.rev.queue}" />
 </bean>
<bean id="
objJms" class="
org.springframework.jms.core.JmsTemplate">
  <property name="connectionFactory" ref="
bxx" />
  <property name="defaultDestination" ref="
qxx" />
 </bean>
 
 <bean id="
oxx" name="oxxx" class="某个自定义的发送类,直接使用自己的变量
jmsTemplate的API进行send消息就ok了">
 
 <property name="jmsTemplate" ref="objJms" />
 </bean>
在service业务类中直接注入“oxx”类,就可以发消息到MQ了,那边一直监听的类就可以取到消息了。

转载地址:http://fpzpa.baihongyu.com/

你可能感兴趣的文章
KlayGE 4.0中Deferred Rendering的改进(一):流水线
查看>>
6-4汉诺塔问题
查看>>
【转载】详解SQL2005/SQL2008动态生成分区脚本的方法
查看>>
构建高性能web之路------mysql读写分离实战(转)
查看>>
2012年网页设计趋势2
查看>>
atmega8 例程:INT1外部中断
查看>>
python类库32[多进程之Pool+Logging]
查看>>
现有portal项目(商业的和开源的)解决方案及优缺点
查看>>
集群(cluster)原理(转)
查看>>
Qt简介以及如何配置Qt使用VS2010进行开发
查看>>
html、html服务器控件和web服务器控件的区别
查看>>
8天玩转并行开发——第四天 同步机制(上)
查看>>
map 取最大value
查看>>
WCF中的异步实现
查看>>
Thrift之代码生成器Compiler原理及源码详细解析2
查看>>
java垃圾回收
查看>>
案例分析:基于消息的分布式架构
查看>>
简单两步走 中兴V880获取权限方法
查看>>
外部 BLOB 存储体系结构
查看>>
导入文本文件时如何指定字段类型.sql
查看>>