activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From dej...@apache.org
Subject activemq git commit: https://issues.apache.org/jira/browse/AMQ-6278 - revisit LeaseDatabaseLocker log levels
Date Tue, 03 May 2016 12:53:38 GMT
Repository: activemq
Updated Branches:
  refs/heads/master ba77b9f55 -> 2e0089182


https://issues.apache.org/jira/browse/AMQ-6278 - revisit LeaseDatabaseLocker log levels


Project: http://git-wip-us.apache.org/repos/asf/activemq/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/2e008918
Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/2e008918
Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/2e008918

Branch: refs/heads/master
Commit: 2e00891827e6e65dd8dbb22d80d1239af3b4ce23
Parents: ba77b9f
Author: Dejan Bosanac <dejan@nighttale.net>
Authored: Tue May 3 14:52:19 2016 +0200
Committer: Dejan Bosanac <dejan@nighttale.net>
Committed: Tue May 3 14:53:31 2016 +0200

----------------------------------------------------------------------
 .../org/apache/activemq/store/jdbc/LeaseDatabaseLocker.java    | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/activemq/blob/2e008918/activemq-jdbc-store/src/main/java/org/apache/activemq/store/jdbc/LeaseDatabaseLocker.java
----------------------------------------------------------------------
diff --git a/activemq-jdbc-store/src/main/java/org/apache/activemq/store/jdbc/LeaseDatabaseLocker.java
b/activemq-jdbc-store/src/main/java/org/apache/activemq/store/jdbc/LeaseDatabaseLocker.java
index e03fbc4..cbbc73d 100644
--- a/activemq-jdbc-store/src/main/java/org/apache/activemq/store/jdbc/LeaseDatabaseLocker.java
+++ b/activemq-jdbc-store/src/main/java/org/apache/activemq/store/jdbc/LeaseDatabaseLocker.java
@@ -83,7 +83,7 @@ public class LeaseDatabaseLocker extends AbstractJDBCLocker {
                 reportLeasOwnerShipAndDuration(connection);
 
             } catch (Exception e) {
-                LOG.debug(getLeaseHolderId() + " lease acquire failure: "+ e, e);
+                LOG.warn(getLeaseHolderId() + " lease acquire failure: "+ e, e);
                 if (isStopping()) {
                     throw new Exception(
                             "Cannot start broker as being asked to shut down. "
@@ -98,7 +98,7 @@ public class LeaseDatabaseLocker extends AbstractJDBCLocker {
                 close(connection);
             }
 
-            LOG.info(getLeaseHolderId() + " failed to acquire lease.  Sleeping for " + lockAcquireSleepInterval
+ " milli(s) before trying again...");
+            LOG.debug(getLeaseHolderId() + " failed to acquire lease.  Sleeping for " + lockAcquireSleepInterval
+ " milli(s) before trying again...");
             TimeUnit.MILLISECONDS.sleep(lockAcquireSleepInterval);
         }
         if (isStopping()) {
@@ -114,7 +114,7 @@ public class LeaseDatabaseLocker extends AbstractJDBCLocker {
             statement = connection.prepareStatement(getStatements().getLeaseOwnerStatement());
             ResultSet resultSet = statement.executeQuery();
             while (resultSet.next()) {
-                LOG.info(getLeaseHolderId() + " Lease held by " + resultSet.getString(1)
+ " till " + new Date(resultSet.getLong(2)));
+                LOG.debug(getLeaseHolderId() + " Lease held by " + resultSet.getString(1)
+ " till " + new Date(resultSet.getLong(2)));
             }
         } finally {
             close(statement);


Mime
View raw message