Merge pull request actionhero#612 from gcoonrod/enhancement/traceLogging

pushing a number of resque logs deeper
evantahler · Mar 16, 2015 · e5720b9 · e5720b9
2 parents 4b8629e + c7c6896
commit e5720b9
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 4 deletions.
diff --git a/config/tasks.js b/config/tasks.js
@@ -5,6 +5,8 @@ exports.default = {
       scheduler: false,
       // what queues should the taskProcessors work?
       queues: ['*'],
+      // Verbosity of task logging
+      verbose: true,
       // how long to sleep between jobs / scheduler checks
       timeout: 5000,
       // at minimum, how many parallel taskProcessors should this node spawn?
@@ -31,4 +33,4 @@ exports.test = {
       checkTimeout: 50
     }  
   }
-}
+}
diff --git a/initializers/resque.js b/initializers/resque.js
@@ -7,6 +7,7 @@ module.exports = {
   initialize: function(api, next){
 
     api.resque = {
+	  verbose: false,
       queue: null,
       multiWorker: null,
       scheduler: null,
@@ -54,6 +55,7 @@ module.exports = {
 
       startMultiWorker: function(callback){
         var self = this;
+		this.verbose = api.config.tasks.verbose;
 
         self.multiWorker = new NR.multiWorker({
           connection:             api.resque.connectionDetails,
@@ -66,9 +68,9 @@ module.exports = {
           toDisconnectProcessors: api.config.tasks.toDisconnectProcessors,
         }, api.tasks.jobs, function(){
           // normal worker emitters
-          self.multiWorker.on('start',             function(workerId){                      api.log('worker: started', 'info',                 {workerId: workerId}                                                            ); })
-          self.multiWorker.on('end',               function(workerId){                      api.log('worker: ended', 'info',                   {workerId: workerId}                                                            ); })
-          self.multiWorker.on('cleaning_worker',   function(workerId, worker, pid){         api.log('worker: cleaning old worker ' + worker + '(' + pid + ')', 'info'                                                                            ); })
+          self.multiWorker.on('start',             function(workerId){                      api.log('worker: started', (self.verbose) ? 'info':'trace', {workerId: workerId}                                                   ); })
+          self.multiWorker.on('end',               function(workerId){                      api.log('worker: ended', (self.verbose) ? 'info':'trace',   {workerId: workerId}                                                   ); })
+          self.multiWorker.on('cleaning_worker',   function(workerId, worker, pid){         api.log('worker: cleaning old worker ' + worker + '(' + pid + ')', (self.verbose) ? 'info':'trace'                                 ); })
           self.multiWorker.on('poll',              function(workerId, queue){               api.log('worker: polling ' + queue, 'trace',       {workerId: workerId}                                                            ); })
           self.multiWorker.on('job',               function(workerId, queue, job){          api.log('worker: working job ' + queue, 'debug',   {workerId: workerId, job: {class: job.class, queue: job.queue}}                 ); })
           self.multiWorker.on('reEnqueue',         function(workerId, queue, job, plugin){  api.log('worker: reEnqueue job', 'debug',          {workerId: workerId, plugin: plugin, job: {class: job.class, queue: job.queue}} ); })