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 <[email protected]> Authored: Tue May 3 14:52:19 2016 +0200 Committer: Dejan Bosanac <[email protected]> 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);
