Mailing-List: contact dev-help@activemq.apache.org; run by ezmlm
Precedence: bulk
Reply-To: dev@activemq.apache.org
Date: Mon, 7 Jul 2014 18:30:35 +0000 (UTC)
From: "Timothy Bish (JIRA)" <jira@apache.org>
To: dev@activemq.apache.org
Message-ID: <JIRA.12725221.1404381083048.14068.1404757835307@arcas>
In-Reply-To: <JIRA.12725221.1404381083048@arcas>
References: <JIRA.12725221.1404381083048@arcas>
Subject: [jira] [Resolved] (AMQ-5258) Connection reference leak in
 PooledConnectionFactory leading to expired connections stuck in the pool
MIME-Version: 1.0
Content-Type: text/plain; charset=utf-8
Content-Transfer-Encoding: 7bit


     [ https://issues.apache.org/jira/browse/AMQ-5258?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Timothy Bish resolved AMQ-5258.
-------------------------------

       Resolution: Fixed
    Fix Version/s: 5.11.0
         Assignee: Timothy Bish

Fixed, connection is created and closed to allow it to reside in the pool as unused and error out or time out as expect. 

> Connection reference leak in PooledConnectionFactory leading to expired connections stuck in the pool
> -----------------------------------------------------------------------------------------------------
>
>                 Key: AMQ-5258
>                 URL: https://issues.apache.org/jira/browse/AMQ-5258
>             Project: ActiveMQ
>          Issue Type: Bug
>          Components: activemq-pool
>    Affects Versions: 5.9.1, 5.10.0
>            Reporter: Sergiy Barlabanov
>            Assignee: Timothy Bish
>             Fix For: 5.11.0
>
>
> org.apache.activemq.jms.pool.PooledConnectionFactory creates a connection on startup without giving it back to the pool:
> {code:java}
>     public void start() {
>         LOG.debug("Staring the PooledConnectionFactory: create on start = {}", isCreateConnectionOnStartup());
>         stopped.set(false);
>         if (isCreateConnectionOnStartup()) {
>             try {
>                 // warm the pool by creating a connection during startup
>                 createConnection();
>             } catch (JMSException e) {
>                 LOG.warn("Create pooled connection during start failed. This exception will be ignored.", e);
>             }
>         }
>     }
> {code}
> So no close() method of PooledConnection is called and so no decrementReferenceCount is called on ConnectionPool. So referenceCount never becomes 0.
> Later on if an exception occurs and hasExpired of ConnectionPool is set to true, the connection will not be closed since expiredCheck() method of ConnectionPool always compares referenceCount with 0 and does close() only if it is 0.
> So we have a dead ConnectionPool instance and all usages result in "XXX closed" errors.
> The fix would be to add call to close() just after doing createConnection() in PooledConnectionFactory#start() to make referenceCount go to 0. Something like this:
> {code:java}
>     public void start() {
>         LOG.debug("Staring the PooledConnectionFactory: create on start = {}", isCreateConnectionOnStartup());
>         stopped.set(false);
>         if (isCreateConnectionOnStartup()) {
>             try {
>                 // warm the pool by creating a connection during startup
>                 createConnection().close(); // <--- makes sure referenceCount goes to 0
>             } catch (JMSException e) {
>                 LOG.warn("Create pooled connection during start failed. This exception will be ignored.", e);
>             }
>         }
>     }
> {code}


--
This message was sent by Atlassian JIRA
(v6.2#6252)