diff --git a/activemq-core/src/main/java/org/apache/activemq/store/jdbc/TransactionContext.java b/activemq-core/src/main/java/org/apache/activemq/store/jdbc/TransactionContext.java
index 57a99c7669..379aff53b6 100755
--- a/activemq-core/src/main/java/org/apache/activemq/store/jdbc/TransactionContext.java
+++ b/activemq-core/src/main/java/org/apache/activemq/store/jdbc/TransactionContext.java
@@ -100,6 +100,10 @@ public class TransactionContext {
     public void close() throws IOException {
         if( !inTx ) {
             try {
+                executeBatch();
+                
+                /**
+                 * we are not in a transaction so should not be committing
                 try{
                     executeBatch();
                 } finally {
@@ -107,6 +111,7 @@ public class TransactionContext {
                         connection.commit();
                     }
                 }
+                */
             } catch (SQLException e) {
                 throw IOExceptionSupport.create(e);
             } finally {