Jboss与IBM MQ的连接泄漏

问题描述 投票:1回答:1

在我的JavaEE应用程序中,我通过以下方式从和MQ MQ队列中读取消息:

 @TransactionAttribute(TransactionAttributeType.REQUIRED)
 public class MyMessageHandler implements MessageListener  {
 @Resource
 private MessageDrivenContext context;

 @Override
 public void onMessage(Message message) {
    try {
        processMessage(message);

    }
    catch (Exception e) {
        context.setRollbackOnly();
    }       
}

该应用程序部署在Jboss EAP 6.4上,并使用wmq.jms.rar适配器(实现版本:7.1.0.0-k000-L111005)。以下是ejb-jar.xml的激活配置:

<message-driven>
    <display-name>MyMessageHandler</display-name>
    <ejb-name>MyMessageHandler</ejb-name>
    <ejb-class>org.example.MyMessageHandler</ejb-class>
    <transaction-type>Container</transaction-type>
    <activation-config>
        <activation-config-property>
            <activation-config-property-name>hostName</activation-config-property-name>
            <activation-config-property-value>${somejbossproperty}</activation-config-property-value>
        </activation-config-property>
        <activation-config-property>
            <activation-config-property-name>port</activation-config-property-name>
            <activation-config-property-value>${somejbossproperty}</activation-config-property-value>
        </activation-config-property>
        <activation-config-property>
            <activation-config-property-name>channel</activation-config-property-name>
            <activation-config-property-value>${somejbossproperty}</activation-config-property-value>
        </activation-config-property>
        <activation-config-property>
            <activation-config-property-name>queueManager</activation-config-property-name>
            <activation-config-property-value>${somejbossproperty}</activation-config-property-value>
        </activation-config-property>
        <activation-config-property>
            <activation-config-property-name>transportType</activation-config-property-name>
            <activation-config-property-value>${somejbossproperty}</activation-config-property-value>
        </activation-config-property>
        <activation-config-property>
            <activation-config-property-name>username</activation-config-property-name>
            <activation-config-property-value>${somejbossproperty}</activation-config-property-value>
        </activation-config-property>
        <activation-config-property>
            <activation-config-property-name>password</activation-config-property-name>
            <activation-config-property-value>${somejbossproperty}</activation-config-property-value>
        </activation-config-property>
        <activation-config-property>
            <activation-config-property-name>destinationType</activation-config-property-name>
            <activation-config-property-value>javax.jms.Queue</activation-config-property-value>
        </activation-config-property>
        <activation-config-property>
            <activation-config-property-name>destination</activation-config-property-name>
            <activation-config-property-value>${somejbossproperty}</activation-config-property-value>
        </activation-config-property>
        <activation-config-property>
            <activation-config-property-name>acknowledgeMode</activation-config-property-name>
            <activation-config-property-value>auto-acknowledge</activation-config-property-value>
        </activation-config-property>
    </activation-config>
</message-driven>

抛出异常时,将回滚事务,并使用IBM MQ回退机制将消息放入IBM MQ回退队列。但是,我注意到连接数量的增长,并且它们没有被释放。这是我监视IBM MQ服务器上的连接数的方法:

echo "display conn(*) all" | runmqsc <queue manager name> | grep <the IP of the Jboss server>| wc -l

为什么会这样?

jms ibm-mq jboss6.x
1个回答
1
投票

似乎问题是由于wmq.jms.rar适配器的版本。当我们升级到更新版本(7.5.0.9-p750-009-180830)时,连接泄漏停止。

© www.soinside.com 2019 - 2024. All rights reserved.