Class: SidekiqReliableRequeue::Middleware

Inherits:
Object
  • Object
show all
Defined in:
lib/sidekiq-reliable-requeue/middleware.rb

Instance Method Summary collapse

Instance Method Details

#call(worker, msg, queue) ⇒ Object 



4
5
6
7
8
9
10
11
 
# 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 ⇒ Object 



18
19
20
 
# 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) ⇒ Object 



13
14
15
16
 
# 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