class AllQ::Release

Public Instance Methods

base_send(job_id, delay) click to toggle source
# File lib/allq/actions/release.rb, line 18
def base_send(job_id, delay)
  {
    'action' => 'release',
    'params' => {
      'job_id' => job_id,
      'delay' => delay
    }
  }
  
end
rcv(data) click to toggle source
# File lib/allq/actions/release.rb, line 13
def rcv(data)
  return nil if data.to_s == '' || data.to_s.strip == '{}'
  JSON.parse(data)
end
snd(data) click to toggle source
# File lib/allq/actions/release.rb, line 4
def snd(data)
  job_id = data[:job_id]
  delay = data[:delay] || 0
  send_data = base_send(job_id, delay)
  response = send_hash_as_json(send_data, true)
  result = rcv(response)
  return result["release"] && result["release"]["job_id"]
end