Class: SidekiqBus::Middleware::Client::Retry
- Inherits:
-
Object
- Object
- SidekiqBus::Middleware::Client::Retry
- Defined in:
- lib/sidekiq_bus/middleware/retry.rb
Overview
ensure sidekiq will retry jobs even when they are enqueued via other adapters
Instance Method Summary collapse
Instance Method Details
#call(_worker_class, job, _queue, _redis_pool) ⇒ Object
8 9 10 11 12 13 14 |
# File 'lib/sidekiq_bus/middleware/retry.rb', line 8 def call(_worker_class, job, _queue, _redis_pool) if job['class'] == 'QueueBus::Worker' job['retry'] = true unless job.key?('retry') job['backtrace'] = true unless job.key?('backtrace') end yield end |