Class: Aservice::Callback

Inherits:
Object
  • Object
show all
Defined in:
lib/aservice/callback.rb

Overview

Sidekiq job callbacks

Class Method Summary collapse

Class Method Details

.add(jid, class_name, method, args) ⇒ Object 



7
8
9
10
11
12
13
14
15
16
17
18
19
 
# File 'lib/aservice/callback.rb', line 7

def add(jid, class_name, method, args)
  opt = {
    'class' => class_name,
    'method' => method,
    'args' => args
  }
  Sidekiq.redis do |conn|
    conn.multi do
      conn.rpush(key(jid), opt.to_json)
      conn.expire(key(jid), Aservice::Config.callbacks_expiration)
    end
  end
end

.failure(job) ⇒ Object 



27
28
29
 
# File 'lib/aservice/callback.rb', line 27

def failure(job)
  clear_stack(job['jid'])
end

.success(job) ⇒ Object 



21
22
23
24
25
 
# File 'lib/aservice/callback.rb', line 21

def success(job)
  while (opt = pop_next(job['jid']))
    execute_service(opt['class'], opt['method'], opt['args'])
  end
end