class AllQ::Put

Public Instance Methods

base_send(tube, body, options = {}) click to toggle source
# File lib/allq/actions/put.rb, line 15
def base_send(tube, body, options = {})
  raise 'Must have tube name and body' unless tube && body
  base = {
    'action' => 'put',
    'params' => {
      'tube' => tube,
      'body' => body
    }
  }
  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']
  base['params']['priority'] = options['priority'] if options['priority']
  return base
end
snd(data) click to toggle source
# File lib/allq/actions/put.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