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