Apache/activemq
1
0
Fork 0
mirror of https://github.com/apache/activemq.git synced 2025-02-12 21:16:06 +00:00
Code Issues Packages Projects Releases Wiki Activity

Applied http://issues.apache.org/activemq/browse/AMQ-711

Browse Source 
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/branches/activemq-4.0@411847 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Hiram R. Chirino 2006-06-05 16:17:40 +00:00
parent 718fd30de2
commit 1774120827
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
activemq-core/src/main/java/org/apache/activemq/store/jdbc/TransactionContext.java
View File

@ -104,7 +104,6 @@ public class TransactionContext {
public void close() throws IOException {
if( !inTx ) {
try {
executeBatch();
/**
* we are not in a transaction so should not be committing ??
@ -115,7 +114,7 @@ public class TransactionContext {
try{
executeBatch();
} finally {
if (connection != null) {
if (connection != null && !connection.getAutoCommit()) {
connection.commit();
}
}
@ -149,7 +148,8 @@ public class TransactionContext {
throw new IOException("Not started.");
try {
executeBatch();
connection.commit();
if( !connection.getAutoCommit() )
connection.commit();
} catch (SQLException e) {
JDBCPersistenceAdapter.log("Commit failed: ", e);
throw IOExceptionSupport.create(e);