class Sidekiq::Middleware::Server::RetryJobs

to the message and everyone is using Airbrake, right?
We don’t store the backtrace as that can add a lot of overhead
* ‘retried_at’ - the last time it was retried
* ‘failed_at’ - the first time it failed
* ‘error_class’ - the exception class
* ‘error_message’ - the message from the exception
* ‘retry_count’ - number of times we’ve retried so far.
* ‘queue’ - the queue to use
We’ll add a bit more data to the message to support retries:
{ ‘class’ => ‘HardWorker’, ‘args’ => [1, 2, ‘foo’] }
A message looks like:
message away.
4. if 3 never happens, sidekiq will eventually give up and throw the
reprocessed successfully.
3. after a few days, a developer deploys a fix. the message is
an exponential delay, the message continues to fail
2. sidekiq retries messages in the retry queue multiple times with
the message and pushes it onto a retry queue
1. bug causes message processing to fail, sidekiq’s middleware captures
0. push some code changes with a bug in it
Sidekiq’s retry support assumes a typical development lifecycle:
Automatically retry jobs that fail in Sidekiq.
#

def call(worker, msg, queue) 

def call(worker, msg, queue)
  yield
rescue Exception => e
  raise e unless msg['retry']
  msg['queue'] = queue
  msg['error_message'] = e.message
  msg['error_class'] = e.class.name
  count = if msg['retry_count']
    msg['retried_at'] = Time.now.utc
    msg['retry_count'] += 1
  else
    msg['failed_at'] = Time.now.utc
    msg['retry_count'] = 0
  end
  if msg['backtrace'] == true
    msg['error_backtrace'] = e.backtrace
  elsif msg['backtrace'].to_i != 0
    msg['error_backtrace'] = e.backtrace[0..msg['backtrace'].to_i]
  end
  if count <= MAX_COUNT
    delay = DELAY.call(count)
    logger.debug { "Failure! Retry #{count} in #{delay} seconds" }
    retry_at = Time.now.to_f + delay
    payload = Sidekiq.dump_json(msg)
    Sidekiq.redis do |conn|
      conn.zadd('retry', retry_at.to_s, payload)
    end
  else
    # Goodbye dear message, you (re)tried your best I'm sure.
    logger.debug { "Dropping message after hitting the retry maximum: #{msg}" }
  end
  raise e
end