Class: Sidekiq::Retries::Server::Middleware
- Inherits:
-
Middleware::Server::RetryJobs
- Object
- Middleware::Server::RetryJobs
- Sidekiq::Retries::Server::Middleware
- Defined in:
- lib/sidekiq/retries/server/middleware.rb
Instance Method Summary collapse
Instance Method Details
#call(worker, msg, queue) ⇒ Object
9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 |
# File 'lib/sidekiq/retries/server/middleware.rb', line 9 def call(worker, msg, queue) yield rescue Sidekiq::Shutdown # ignore, will be pushed back onto queue during hard_shutdown raise rescue Sidekiq::Retries::Retry => e # force a retry (for workers that have retries disabled) msg['retry'] = e.max_retries || '1' attempt_retry(worker, msg, queue, e.cause) raise e.cause rescue Sidekiq::Retries::Fail => e # seriously, don't retry this raise e.cause rescue Exception => e attempt_retry(worker, msg, queue, e) if msg['retry'] raise e end |