Class: AttentiveSidekiq::Disappeared

Inherits:
RedisBasedHash show all
Defined in:
lib/attentive_sidekiq/api.rb

Constant Summary collapse

STATUS_DETECTED = 
'detected'
STATUS_REQUEUED = 
'requeued'

Class Method Summary collapse

Methods inherited from RedisBasedHash

get_job, job_ids, jobs, remove

Class Method Details

.add(item) ⇒ Object 



33
34
35
36
 
# File 'lib/attentive_sidekiq/api.rb', line 33

def add item
  extended_item = {'noticed_at' => Time.now.to_i, 'status' => STATUS_DETECTED}.merge(item)
  super extended_item
end

.base_add ⇒ Object 



31
 
# File 'lib/attentive_sidekiq/api.rb', line 31

alias_method :base_add, :add

.hash_name ⇒ Object 



44
45
46
 
# File 'lib/attentive_sidekiq/api.rb', line 44

def hash_name
  AttentiveSidekiq::REDIS_DISAPPEARED_KEY
end

.requeue(jid) ⇒ Object 



38
39
40
41
42
 
# File 'lib/attentive_sidekiq/api.rb', line 38

def requeue jid
  record = get_job(jid)
  record['class'].constantize.perform_async(*record['args'])
  base_add(record.merge('status' => STATUS_REQUEUED))
end