class AllQ::ParentJob
Public Instance Methods
base_send(tube, body, options = {})
click to toggle source
# File lib/allq/actions/parent_job.rb, line 15 def base_send(tube, body, options = {}) raise 'Must have tube name and body' unless tube && body base = { 'action' => 'set_parent_job', 'params' => { 'tube' => tube, 'body' => body } } base['params']['limit'] = options['limit'] if options['limit'] base['params']['noop'] = options['noop'] if options['noop'] base['params']['ttl'] = options['ttl'] if options['ttl'] base['params']['delay'] = options['delay'] if options['delay'] base['params']['parent_id'] = options['parent_id'] if options['parent_id'] return base end
snd(data)
click to toggle source
# File lib/allq/actions/parent_job.rb, line 4 def snd(data) result = nil tube = data.delete('tube') body = data.delete('body') send_data = base_send(tube, body, data) response = send_hash_as_json(send_data) result = rcv(response) build_job(result) end