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