mirror of
https://github.com/mperham/sidekiq.git
synced 2022-11-09 13:52:34 -05:00
fix missing component usage
This commit is contained in:
parent
2b58b74344
commit
8e3dd2e6e8
1 changed files with 2 additions and 2 deletions
|
@ -176,7 +176,7 @@ module Sidekiq
|
||||||
# logger.debug { "Failure! Retry #{count} in #{delay} seconds" }
|
# logger.debug { "Failure! Retry #{count} in #{delay} seconds" }
|
||||||
retry_at = Time.now.to_f + delay
|
retry_at = Time.now.to_f + delay
|
||||||
payload = Sidekiq.dump_json(msg)
|
payload = Sidekiq.dump_json(msg)
|
||||||
Sidekiq.redis do |conn|
|
redis do |conn|
|
||||||
conn.zadd("retry", retry_at.to_s, payload)
|
conn.zadd("retry", retry_at.to_s, payload)
|
||||||
end
|
end
|
||||||
else
|
else
|
||||||
|
@ -195,7 +195,7 @@ module Sidekiq
|
||||||
|
|
||||||
send_to_morgue(msg) unless msg["dead"] == false
|
send_to_morgue(msg) unless msg["dead"] == false
|
||||||
|
|
||||||
Sidekiq.death_handlers.each do |handler|
|
config.death_handlers.each do |handler|
|
||||||
handler.call(msg, exception)
|
handler.call(msg, exception)
|
||||||
rescue => e
|
rescue => e
|
||||||
handle_exception(e, {context: "Error calling death handler", job: msg})
|
handle_exception(e, {context: "Error calling death handler", job: msg})
|
||||||
|
|
Loading…
Add table
Reference in a new issue