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) {
