Spring MDP：轮询间隔？

Question

客户使用此模式：

• Apache的骆驼和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> 

问题：在WebSphere MQ管理员报告MGET的啤酒数（）对队列管理器的请求。目前的假设是，那些接收者不断地轮询新频道。

它们似乎没有MDB（消息驱动bean）的这个问题。 MDP异步实现是否真的是轮询机制？如果是这样，是否有办法限制队列管理器的访问？也许增加轮询间隔？任何见解，将不胜感激。

Answer 1

我不知道CXF，但骆驼听众：

好像在JmsConfiguration默认JMS消费的类型是“违约”。 这意味着，它将实现Spring的DefaultMessageListenerContainer。

从Javadoc

使用纯JMS客户端API消息监听器容器的变体，特别是MessageConsumer.receive的环（）调用

接收调用将映射到MQ GET呼叫。

还有一个选项可以指定一个Simple类型的消费者，我猜是你想要的。

使用普通JMS客户端API的MessageConsumer.setMessageListener（）

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

Answer 2

我们也有类似的问题，我们的大型机问：IBM大型机问：

注意，应用程序ID作为默认的用户身份 要传递给队列管理器。如果应用程序是在客户端传输模式下运行的 ，则该进程ID必须与 存在于服务器计算机上的相关授权一起存在。如果需要不同的身份，则应用程序应使用 createConnection（用户名，密码）方法。

或者换句话说，IBM使用JVM进程ID登录到MQ，除非我们在适当的凭据发送。我们在使用Spring，所以每次我们的DefaultMessageListenerContainer轮询Q时，都必须使用它发送凭证。我迷上了这些宝宝之一和巴姆，像一个魅力工作：

public class CustomConnectionFactory extends CachingConnectionFactory { 

    private String username; 
    private String password; 

    ... 

    /** 
    * This is the secret sauce. Each time when we make a connection, we send 
    * the username/password. 
    */ 
    protected Connection doCreateConnection() throws JMSException { 
     return getTargetConnectionFactory().createConnection(this.username, this.password); 
    } 

我们的主机更快乐。我们后来转而使用分布式MQ，并且一切都好多了！

这是我们最后的安装：

<!-- This hooks us up to the jndi --> 
<jee:jndi-lookup id="telematicsJNDIConnectionFactory" jndi-name="${mq.jndi}" cache="true" lookup-on-startup="true" /> 
<!-- The outer wrapper must be TransactionAware, the inner custom one will cache the connection --> 
<bean id="telematicsConnectionFactory" class="org.springframework.jms.connection.TransactionAwareConnectionFactoryProxy"> 
    <property name="targetConnectionFactory"> 
     <bean class="cat.dds.tmatic.utils.CustomConnectionFactory"> 
      <property name="targetConnectionFactory"> 
       <ref bean="telematicsJNDIConnectionFactory" /> 
      </property> 
      <property name="username"> 
       <value>${mq.user}</value> 
      </property> 
      <property name="password"> 
       <value>${mq.pass}</value> 
      </property> 
      <property name="sessionCacheSize"> 
       <value>10</value> 
      </property> 
     </bean> 
    </property> 
    <property name="synchedLocalTransactionAllowed" value="true" /> 
</bean>