class AllQ::Peek
Public Instance Methods
base_send(tube, buried)
click to toggle source
# File lib/allq/actions/peek.rb, line 26 def base_send(tube, buried) out = { 'action' => 'peek', 'params' => { 'tube' => tube } } out['params']['buried'] = 'true' if buried out end
rcv(data)
click to toggle source
# File lib/allq/actions/peek.rb, line 14 def rcv(data) return nil if data.to_s == '' || data.to_s.strip == '{}' result = JSON.parse(data) if result['job'] return nil if result['job'].empty? job = Job.new_from_hash(result['job'], @client) return job end nil end
snd(data)
click to toggle source
# File lib/allq/actions/peek.rb, line 4 def snd(data) result = nil tube = data.delete(:tube) buried = data.delete(:buried) send_data = base_send(tube, buried) response = send_hash_as_json(send_data) rcv(response) end