春季JMS發佈/訂戶配置到IBM Webpshere MQ

Question

在網上搜索我發現了很多關於如何爲活動MQ發佈/訂閱者模式配置spring（file.xml）的例子，但我需要如何bean需要針對Websphere MQ進行配置MQ 任何人都已將產品配置成功？

Answer 1

下面是bean定義一個的WebSphere MQ ConnectionFactory：

<bean id="wmqConnectionFactory" class="com.ibm.mq.jms.MQConnectionFactory"> 
    <property name="queueManager"> 
     <value>QUEUE_MANAGER</value> 
    </property> 
    <property name="hostName"> 
     <value>127.0.0.1</value> 
    </property> 
    <property name="port"> 
     <value>1414</value> 
    </property> 
    <property name="transportType"> 
     <value>1</value> 
    </property> 
    <property name="channel"> 
     <value>SYSTEM.DEF.SVRCONN</value> 
    </property> 
</bean> 

您可能需要提供用戶名和密碼，就可以實現這個目標通過在UserCredentialsConnectionFactoryAdapter包裹它：

<bean id="userCredentialsAdapter" class="org.springframework.jms.connection.UserCredentialsConnectionFactoryAdapter"> 
    <property name="targetConnectionFactory" ref="wmqConnectionFactory" /> 
    <property name="username" value=" " /> 
    <property name="password" value=" " /> 
</bean> 

將它包裝在CachingConnectionFactory中以便會話，消費者和生產者被緩存也是一個好主意，這個包裝也將自動恢復切換爲真：

<bean id="cachingConnectionFactory" class="org.springframework.jms.connection.CachingConnectionFactory"> 
    <property name="targetConnectionFactory" ref="userCredentialsAdapter"/> 
    <property name="cacheConsumers" value="true" /> 
    <property name="cacheProducers" value="true" /> 
    <property name="sessionCacheSize" value="10" /> 
</bean> 

使用此配置，您可以使用cachingConnectionFactory以及任何您需要的bean。