Spring JMS和Websphere MQ

这是使用Spring MDP / Activation Spec for Websphere MQ的工作示例

mdp-listener.xml

<?xml version="1.0" encoding="UTF-8"?><!DOCTYPE beans PUBLIC "-//SPRING//DTD BEAN//EN"          "http://www.springframework.org/dtd/spring-beans.dtd">     <bean id="messageListener"  />       <bean >         <property name="activationSpec"><bean >    <property name="destinationType" value="javax.jms.Queue"/>    <property name="destination" value="QUEUE1"/>    <property name="hostName" value="A.B.C"/>        <property name="queueManager" value="QM_"/>    <property name="port" value="1414"/>    <property name="channel" value="SYSTEM.ADMIN.SVNNN"/>    <property name="transportType" value="CLIENT"/>    <property name="userName" value="abc"/>    <property name="password" value="jabc"/> </bean>          </property>          <property name="messageListener" ref="messageListener"/>          <property name="resourceAdapter" ref="myResourceAdapterBean"/>    </bean>    <bean id="myResourceAdapterBean" class ="org.springframework.jca.support.ResourceAdapterFactoryBean">      <property name="resourceAdapter">        <bean >          <property name="maxConnections" value="50"/>        </bean>      </property>      <property name="workManager">         <bean />      </property>     </bean></beans>

web.xml

<context-param>   <param-name>contextConfigLocation</param-name>   <param-value>/WEB-INF/context/mdp-listener.xml</param-value> </context-param><listener>       <listener-class>org.springframework.web.context.ContextLoaderListener</listener-class></listener>

SpringMdp

   package com.rohid.samples;  import javax.jms.JMSException;  import javax.jms.Message;  import javax.jms.MessageListener;  import javax.jms.TextMessage;  public class SpringMdp implements MessageListener {     public void onMessage(Message message) {        try {if(message instanceof TextMessage) {   System.out.println(this + " : " + ((TextMessage) message).getText());}        } catch (JMSException ex){throw new RuntimeException(ex);        }     }  }