class SidekiqReliableRequeue::Middleware

Public Instance Methods

call(worker, msg, queue) { || ... } click to toggle source
# File lib/sidekiq-reliable-requeue/middleware.rb, line 4
def call(worker, msg, queue)
  if msg['reliable_requeue']
    set_stale_info(msg)
  end
  yield
ensure
  clean_stale_info
end
clean_stale_info() click to toggle source
# File lib/sidekiq-reliable-requeue/middleware.rb, line 18
def clean_stale_info
  RedisConnection.hdel(SidekiqReliableStaleJobsKey, @redis_key_for_check)
end
set_stale_info(msg) click to toggle source
# File lib/sidekiq-reliable-requeue/middleware.rb, line 13
def set_stale_info(msg)
  @redis_key_for_check = "#{msg['class']}:#{msg['jid']}"
  RedisConnection.hset(SidekiqReliableStaleJobsKey, @redis_key_for_check, msg.to_json)
end