class AllQ::Kick

Public Instance Methods

base_send(job) click to toggle source
# File lib/allq/actions/kick.rb, line 13
def base_send(job)
  {
    'action' => 'kick',
    'params' => {
      'job_id' => job.id,
      'tube' => job.tube
    }
  }
end
snd(data) click to toggle source
# File lib/allq/actions/kick.rb, line 4
def snd(data)
  result = nil
  job = data[:job]

  send_data = base_send(job)
  response = send_hash_as_json(send_data, true)
  rcv(response)
end