Repository: usergrid Updated Branches: refs/heads/QueueJobLoggingDebug [created] 28284cfea
QueueLogging has been changed so that it A: doesn't flood the logs whenever we run a check for a job B: tell us whenever it drives to get the queued. Project: http://git-wip-us.apache.org/repos/asf/usergrid/repo Commit: http://git-wip-us.apache.org/repos/asf/usergrid/commit/28284cfe Tree: http://git-wip-us.apache.org/repos/asf/usergrid/tree/28284cfe Diff: http://git-wip-us.apache.org/repos/asf/usergrid/diff/28284cfe Branch: refs/heads/QueueJobLoggingDebug Commit: 28284cfead2c8684df5dd5ea180e1cf7447063e7 Parents: 9950af7 Author: George Reyes <[email protected]> Authored: Tue Apr 19 12:45:50 2016 -0700 Committer: George Reyes <[email protected]> Committed: Tue Apr 19 12:45:50 2016 -0700 ---------------------------------------------------------------------- .../org/apache/usergrid/batch/service/JobSchedulerService.java | 4 +++- .../java/org/apache/usergrid/mq/cassandra/CassandraMQUtils.java | 4 +++- 2 files changed, 6 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/usergrid/blob/28284cfe/stack/core/src/main/java/org/apache/usergrid/batch/service/JobSchedulerService.java ---------------------------------------------------------------------- diff --git a/stack/core/src/main/java/org/apache/usergrid/batch/service/JobSchedulerService.java b/stack/core/src/main/java/org/apache/usergrid/batch/service/JobSchedulerService.java index 50bd9bc..807daa3 100644 --- a/stack/core/src/main/java/org/apache/usergrid/batch/service/JobSchedulerService.java +++ b/stack/core/src/main/java/org/apache/usergrid/batch/service/JobSchedulerService.java @@ -93,7 +93,9 @@ public class JobSchedulerService extends AbstractScheduledService { failCounter = metricsFactory.getCounter( JobSchedulerService.class, "scheduler.failed_jobs" ); try { - logger.info( "Running one check iteration ..." ); + if ( logger.isDebugEnabled() ) { + logger.debug( "Running one check iteration ..." ); + } List<JobDescriptor> activeJobs; // run until there are no more active jobs http://git-wip-us.apache.org/repos/asf/usergrid/blob/28284cfe/stack/core/src/main/java/org/apache/usergrid/mq/cassandra/CassandraMQUtils.java ---------------------------------------------------------------------- diff --git a/stack/core/src/main/java/org/apache/usergrid/mq/cassandra/CassandraMQUtils.java b/stack/core/src/main/java/org/apache/usergrid/mq/cassandra/CassandraMQUtils.java index d48b6d2..388c895 100644 --- a/stack/core/src/main/java/org/apache/usergrid/mq/cassandra/CassandraMQUtils.java +++ b/stack/core/src/main/java/org/apache/usergrid/mq/cassandra/CassandraMQUtils.java @@ -244,7 +244,9 @@ public class CassandraMQUtils { queuePath = "/"; } - logger.info( "QueueManagerFactoryImpl.getFromQueue: {}", queuePath ); + if ( logger.isDebugEnabled() ) { + logger.debug( "QueueManagerFactoryImpl.getFromQueue: {}", queuePath ); + } return Queue.getQueueId( queuePath ); }
