<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:util="http://www.springframework.org/schema/util"
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.5.xsd http://www.springframework.org/schema/util http://www.springframework.org/schema/util/spring-util-2.5.xsd">
<!-- IBM的mq配置 ConnectionFactory-->
<bean id="mqConnectionFactoryTarget" class="com.ibm.mq.jms.MQTopicConnectionFactory">
<!-- -->
<property name="transportType">
<util:constant static-field="com.ibm.mq.jms.JMSC.MQJMS_TP_CLIENT_MQ_TCPIP" />
</property>
<property name="queueManager" value="${ibm_queueManager}" />
<property name="hostName" value="${ibm_hostName}" />
<property name="port" value="${ibm_port}" />
</bean>
<bean id="mqConnectionFactory"
class="org.springframework.jms.connection.UserCredentialsConnectionFactoryAdapter">
<property name="targetConnectionFactory" ref="mqConnectionFactoryTarget" />
<property name="username" value=" " />
<property name="password" value=" " />
</bean>
<bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate" >
<property name="connectionFactory" ref="mqConnectionFactory" />
</bean>
<!-- Topic定义 -->
<bean id="notifyTopic" class="com.ibm.mq.jms.MQTopic">
<constructor-arg value="${ibm_topicName}" />
</bean>
</beans>
<!-- 异步接收Topic消息Container
<property name="connectionFactory" ref="jmsFactory" />-->
<bean id="jmsContainer" class="org.springframework.jms.listener.DefaultMessageListenerContainer" lazy-init="false">
<property name="connectionFactory" ref="mqConnectionFactory" />
<property name="destination" ref="notifyTopic" />
<property name="messageListener" ref="notifyTopicListener" />
</bean>
<!-- 异步接收Topic消息处理类 -->
<bean id="notifyTopicListener" class="com.liuyu.examples.jms.NotifyTopicListener" />
分享到:
相关推荐
1) 本工程主要演示在SPRING BOOT工程中怎样使用JMS集成IBM-MQ及TLQ两种消息中间件产品 2) 使用SPRING BOOT Conditional机制实现了两种产品按需加载,工程会根据配置文件开关动态加载 3) 实现了普通队列消息发送与...
Spring 集成 IBM MQ 监听配置,包括用户管理配置和一些基础配置信息
JMS 操作IBM MQ,实现订阅发布模式!包含完整的JAR包以及测试文件。
目的:通过JMS 实现 IBM MQ的请求应答功能 工作原理:消息生产者发送消息到队列IN1,然后可以异步或者同步等待消费者接收到IN1消息后,生成应答消息,并发布到IN2队列中。生产者通过messageid在IN2队列中进行消息...
NULL 博文链接:https://qiaokeli.iteye.com/blog/1782656
JMS 客户端模式实现服务端、客户端;实现同步以及异步的收发处理;
这是一个使用Spring 链接IBM MQ的Demo,MQ版本是7.5,经测试是好用滴~
Java连接IBM WebSphere MQ 7处理队列信息所需jar包,从安装目录直接打的包。主要包括: /com.ibm.mq.commonservices.jar /com.ibm.mq.defaultconfig.jar /com.ibm.mq.fta.jar /com.ibm.mq.headers.jar /...
IBM MQ JMS Spring组件该存储库包含有助于向Spring开发人员提供IBM MQ JMS软件包的轻松配置的代码。 该库包含: 用于应用程序的mq-jms-spring-boot-starter安装及使用该软件包的编译版本可以从Maven Central自动下载...
JAVA IBM MQ 接收消息、发送消息例子
IBM MQ将消息发送至远程队列,文档详细,有截图,有命令
A IBM MQ client is part of the product that can be installed on its own, on a separate machine from the base product and server. You can run an IBM MQ application on an IBM MQ client and it can ...
一个C#实现IBM WebSphere MQ 消息收发的实例,包含 发送接收等. 使用的时候只需要修改 appconfig 文件的内容即可. 如有问题.请留言
利用IBMMQ实现远程消息安全传递 利用IBMMQ实现远程消息安全传递
spring boot jsm ibmmq topic queue 两种方式实现
JAVA连接IBM MQ,具体的详细说明,请再csdn上面搜索JAVA连接IBM MQ关键词
工程可以导入直接运行,里面有说明文件!里面书写了直接生成工厂和使用连接池的运行效果,可以非常清晰的学习关于MQ的连接池使用。
java IBM MQ 7.5.0 生产者和消费者实例
下载后解压即可使用,专门测试远程和本地IBMMQ数据,可以导入导出数据
jmeter插件,用于进行IBM MQ测试。 部署插件之后,可进行简单配置,即可发送消息到mq通道中 使用方法参见 https://testerhome.com/notes/2193