svn commit: r703482 - /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/jdbc/DefaultDatabaseLocker.java

[chirino]

Author: chirino
Date: Fri Oct 10 07:01:59 2008
New Revision: 703482

URL: http://svn.apache.org/viewvc?rev=703482&view=rev
Log:
AMQ-1972

Modified:
    
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/jdbc/DefaultDatabaseLocker.java

Modified: 
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/jdbc/DefaultDatabaseLocker.java
URL: 
http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/jdbc/DefaultDatabaseLocker.java?rev=703482&r1=703481&r2=703482&view=diff
==============================================================================
--- 
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/jdbc/DefaultDatabaseLocker.java
 (original)
+++ 
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/jdbc/DefaultDatabaseLocker.java
 Fri Oct 10 07:01:59 2008
@@ -92,14 +92,6 @@
                     }
                     statement = null;
                 }
-                if (null != connection) {
-                    try {
-                        connection.close();
-                    } catch (SQLException e1) {
-                        LOG.warn("Caught while closing connection: " + e1, e1);
-                    }
-                    connection = null;
-                }
             }
 
             LOG.debug("Sleeping for " + lockAcquireSleepInterval + " milli(s) 
before trying again to get the lock...");