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
48 49 50 |
# File 'lib/resque/durable/queue_audit.rb', line 48 def cleanup(date) older_than(date).delete_all end |
#recover ⇒ Object
37 38 39 40 41 42 43 44 45 46 |
# File 'lib/resque/durable/queue_audit.rb', line 37 def recover failed.each do |audit| begin audit.enqueue if audit.retryable? rescue => e = "#{e.class.name}: #{e.}\n#{(e.backtrace || []).join("\n")}" logger && logger.error("Failed to retry audit #{audit.enqueued_id}: #{}") end end end |