Spring JMS 发布/订阅配置到 IBM Websphere MQ

Question

在网上搜索我发现了很多关于如何为活动 MQ 的发布/订阅者模式配置 spring (file.xml) 的示例，但我需要如何为 Websphere MQ 配置 bean 有人成功配置过这两种产品吗？

Answer 1

以下是 Websphere MQ ConnectionFactory 的 bean 定义：

<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 中也是一个好主意，以便缓存会话、消费者和生产者，此包装器还将自动恢复切换为 true：

<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 一起使用。