You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by de...@apache.org on 2016/05/03 14:53:38 UTC
activemq git commit: https://issues.apache.org/jira/browse/AMQ-6278 -
revisit LeaseDatabaseLocker log levels
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 <de...@nighttale.net>
Authored: Tue May 3 14:52:19 2016 +0200
Committer: Dejan Bosanac <de...@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);