module Resque::SilenceDone
def self.included(receiver)
def self.included(receiver) receiver.class_eval do alias work_one_job_with_log work_one_job alias work_one_job work_one_job_no_log alias perform_with_log perform alias perform perform_no_log end end
def perform_no_log(job)
def perform_no_log(job) begin if fork_per_job? reconnect run_hook :after_fork, job end job.perform rescue Object => e report_failed_job(job,e) else # log_with_severity :info, "done: #{job.inspect}" ensure yield job if block_given? end end
def work_one_job_no_log(job = nil, &block)
def work_one_job_no_log(job = nil, &block) return false if paused? return false unless job ||= reserve working_on job procline "Processing #{job.queue} since #{Time.now.to_i} [#{job.payload_class_name}]" #log_with_severity :info, "got: #{job.inspect}" job.worker = self if fork_per_job? perform_with_fork(job, &block) else perform(job, &block) end done_working true end