lib/q4m.rb in q4m-0.0.1 vs lib/q4m.rb in q4m-0.0.2

@@ -25,10 +25,11 @@
       # - Restores the queue so other worker can execute a process.
       #
       def run
         return unless @has_jobs
         queue_wait
+        @log.info("Executing: #{latest_job.inspect}")
         execute latest_job
         queue_end
       end
 
       private
@@ -98,9 +99,10 @@
       # When this happens the job is restored to the queue for later
       # processing. But you should still unlock the queue so it can
       # start serving other workers
       #
       def queue_abort
+        @log.error 'Aborted!'
         @mysql.query 'select queue_abort()'
       end
 
       # Job table name.
       #