JMS如何调用webshere MQ中间件收发消息

泥巴刀儿 发布于 2014/01/14 10:59
阅读 1K+
收藏 0

问题描述:

有个应用原先是用ibm MQ插件包调用websphere MQ消息并发消息。最近需要进行转移,改用原生的JMS调用,小弟初学,不知道如何通过JMS配置项对应的队列管理器,通道和队列。是否用JMS调用,websphere MQ必须和应用部署在同一台服务器上呢?

这里高手如云,希望大侠们指点迷津。小弟万分感谢

 

加载中
0
mengjunxiaoxiang
mengjunxiaoxiang

这个网上很多的,用jms发mq消息比ibm MQ插件包调用的时候 ,可以在网络断开的情况下自动重连。

先配置一个connectionFactory:

<bean id="jmsConnectionFactory1" class="com.ibm.mq.jms.MQQueueConnectionFactory">
		<property name="hostName" value="${jms.mq.server}" />
		<property name="port" value="${jms.mq.port}" />
		<property name="CCSID" value="${jms.mq.ccsid}" />
		<property name="queueManager" value="${jms.mq.queueManager}" />
	</bean>
	 
	<bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate">
		<property name="connectionFactory" ref="jmsConnectionFactory1" />
		<property name="pubSubDomain" value="false" />
	</bean>
<bean id="messageService"
 class="XX.service.impl.MessageServiceImpl">
 <property name="jmsTemplate" ref="jmsTemplate" />
 <property name="destinationName" value="${jms.queue.announce}" />
 </bean>       
MessageServiceImpl里写发送jms消息的代码                              


jmsTemplate.send(destinationName, new MessageCreator() {
			public Message createMessage(Session session) throws JMSException {
				Message message = null;
				message = session.createTextMessage(xml);
				return message;
			}
		});




websphere MQ必须和应用部署在同一台服务器上呢?

这个问题问的,没有理由....答案是肯定不需要,但是可以在一台服务器上。





0
泥巴刀儿
泥巴刀儿
这个你用到了spring框架吧,不过还是谢谢你了。
返回顶部
顶部