From fb72e6cc7281aab7c54a3e143249671020d712a8 Mon Sep 17 00:00:00 2001 From: James Strachan Date: Mon, 30 Apr 2007 12:41:11 +0000 Subject: [PATCH] Backported fix for JDBC master/slave from trunk to 4.1 branch for AMQ-1236 git-svn-id: https://svn.apache.org/repos/asf/activemq/branches/activemq-4.1@533725 13f79535-47bb-0310-9956-ffa450edef68 --- .../apache/activemq/store/jdbc/DefaultDatabaseLocker.java | 6 ++---- 1 file changed, 2 insertions(+), 4 deletions(-) diff --git a/activemq-core/src/main/java/org/apache/activemq/store/jdbc/DefaultDatabaseLocker.java b/activemq-core/src/main/java/org/apache/activemq/store/jdbc/DefaultDatabaseLocker.java index 145ff14402..e0e349e17c 100644 --- a/activemq-core/src/main/java/org/apache/activemq/store/jdbc/DefaultDatabaseLocker.java +++ b/activemq-core/src/main/java/org/apache/activemq/store/jdbc/DefaultDatabaseLocker.java @@ -56,10 +56,8 @@ public class DefaultDatabaseLocker implements DatabaseLocker { 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) {