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 2007/04/30 14:41:12 UTC

svn commit: r533725 - /activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/store/jdbc/DefaultDatabaseLocker.java

Author: jstrachan
Date: Mon Apr 30 05:41:11 2007
New Revision: 533725

URL: http://svn.apache.org/viewvc?view=rev&rev=533725
Log:
Backported fix for JDBC master/slave from trunk to 4.1 branch for AMQ-1236

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

Modified: activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/store/jdbc/DefaultDatabaseLocker.java
URL: http://svn.apache.org/viewvc/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/store/jdbc/DefaultDatabaseLocker.java?view=diff&rev=533725&r1=533724&r2=533725
==============================================================================
--- activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/store/jdbc/DefaultDatabaseLocker.java (original)
+++ activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/store/jdbc/DefaultDatabaseLocker.java Mon Apr 30 05:41:11 2007
@@ -56,10 +56,8 @@
         while (true) {
             try {
                 log.info("Attempting to acquire the exclusive lock to become the Master broker");
-                boolean answer = statement.execute();
-                if (answer) {
-                    break;
-                }
+                statement.execute();
+				break;
             }
             catch (Exception e) {
                 if (stopping) {