From 9f6efd4b1f2594cd2b41d2c297173c88025b372f Mon Sep 17 00:00:00 2001
From: "Hiram R. Chirino" <chirino@apache.org>
Date: Fri, 25 Sep 2009 18:10:12 +0000
Subject: [PATCH] AMQ-2414: Fixing the failing create tables problem on MySQL
 cluster.

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@818936 13f79535-47bb-0310-9956-ffa450edef68
---
 .../apache/activemq/store/jdbc/adapter/DefaultJDBCAdapter.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/activemq-core/src/main/java/org/apache/activemq/store/jdbc/adapter/DefaultJDBCAdapter.java b/activemq-core/src/main/java/org/apache/activemq/store/jdbc/adapter/DefaultJDBCAdapter.java
index 8df17e716a..8f9f119666 100755
--- a/activemq-core/src/main/java/org/apache/activemq/store/jdbc/adapter/DefaultJDBCAdapter.java
+++ b/activemq-core/src/main/java/org/apache/activemq/store/jdbc/adapter/DefaultJDBCAdapter.java
@@ -103,8 +103,8 @@ public class DefaultJDBCAdapter implements JDBCAdapter {
                         JDBCPersistenceAdapter.log("Failure details: ", e);
                     }
                 }
+                c.getConnection().commit();
             }
-            c.getConnection().commit();
         } finally {
             try {
                 s.close();