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
49 50 51 |
# File 'lib/resque/durable/queue_audit.rb', line 49 def cleanup(date) older_than(date).destroy_all end |
#recover ⇒ Object
38 39 40 41 42 43 44 45 46 47 |
# File 'lib/resque/durable/queue_audit.rb', line 38 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 |