| commit | 28284cfead2c8684df5dd5ea180e1cf7447063e7 | [log] [tgz] |
|---|---|---|
| author | George Reyes <grey@apache.org> | Tue Apr 19 12:45:50 2016 -0700 |
| committer | George Reyes <grey@apache.org> | Tue Apr 19 12:45:50 2016 -0700 |
| tree | 9c96a491b3d6eb56d84007b4fbf13f1c865e0852 | |
| parent | 9950af7684255e1949637ddbb8ca8effa74498a3 [diff] |
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.
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 @@ 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
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 @@ queuePath = "/"; } - logger.info( "QueueManagerFactoryImpl.getFromQueue: {}", queuePath ); + if ( logger.isDebugEnabled() ) { + logger.debug( "QueueManagerFactoryImpl.getFromQueue: {}", queuePath ); + } return Queue.getQueueId( queuePath ); }