Module: Resque::Durable::QueueAudit::Recovery

Included in:
Resque::Durable::QueueAudit
Defined in:
lib/resque/durable/queue_audit.rb

Instance Method Summary collapse

Instance Method Details

#cleanup(date) ⇒ Object 



50
51
52
 
# File 'lib/resque/durable/queue_audit.rb', line 50

def cleanup(date)
  older_than(date).destroy_all
end

#recover ⇒ Object 



39
40
41
42
43
44
45
46
47
48
 
# File 'lib/resque/durable/queue_audit.rb', line 39

def recover
  failed.each do |audit|
    begin
      audit.enqueue if audit.retryable?
    rescue => e
      message = "#{e.class.name}: #{e.message}\n#{(e.backtrace || []).join("\n")}"
      logger && logger.error("Failed to retry audit #{audit.enqueued_id}: #{message}")
    end
  end
end