Spring MDP：轮询间隔？

Question

客户使用此模式：

• Apache Camel和CXF JMS接收器
• 它们在内部使用Spring MDP（消息驱动POJO）来实现它们的消息接收器
• 它们部署在IBM WebSphere Application Server 7上
• 队列管理器是IBM Websphere MQ 6
• Spring MDP使用JNDI队列连接工厂绑定到队列管理器--支持连接池和会话池

<bean id="ibmmq" class="org.apache.camel.component.jms.JmsComponent">
    <property name="configuration" ref="jmsConfig"/>
</bean>

<!-- JNDI reference to the queue manager -->
<jee:jndi-lookup id="myTargetConnectionFactory" jndi-name="${mq.queueconnectionfactory}"/>

<bean id="jmsDestResolver" class="org.springframework.jms.support.destination.JndiDestinationResolver"/>

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

<bean id="jmsConfig" class="org.apache.camel.component.jms.JmsConfiguration">

    <property name="connectionFactory" ref="${mq.connectionfactorybean}" />        
    <property name="destinationResolver" ref="jmsDestResolver" />        
    <property name="concurrentConsumers" value="1" />
    <property name="maxConcurrentConsumers" value="1" />

    <!--
        NOTE: If we try to use a cache without a transactionManager we get "Connection closed" errors
    -->
    <property name="cacheLevelName" value="CACHE_NONE" />
</bean>

Answer 1

我不确定CXF，但对于骆驼听众来说：

JmsConfiguration中的默认JMS使用者似乎属于“default”类型。方法，它将从Spring实现一个DefaultMessageListenerContainer。

来自Javadoc

我在这里不确定，但Spring文档表明简单的消息侦听器容器不支持XA事务。这可能是需要考虑的问题，因为您正在应用程序服务器中运行。