You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by js...@apache.org on 2006/07/22 12:24:37 UTC
svn commit: r424542 -
/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/jdbc/DefaultDatabaseLocker.java
Author: jstrachan
Date: Sat Jul 22 03:24:31 2006
New Revision: 424542
URL: http://svn.apache.org/viewvc?rev=424542&view=rev
Log:
fixed shut down bug; the connection must be rolled back before closing
Modified:
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/jdbc/DefaultDatabaseLocker.java
Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/jdbc/DefaultDatabaseLocker.java
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/jdbc/DefaultDatabaseLocker.java?rev=424542&r1=424541&r2=424542&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/jdbc/DefaultDatabaseLocker.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/jdbc/DefaultDatabaseLocker.java Sat Jul 22 03:24:31 2006
@@ -71,6 +71,7 @@
public void stop() throws Exception {
if (connection != null) {
+ connection.rollback();
connection.close();
}
}