class Talkshow::Queue

Attributes

url[RW]

Public Class Methods

new(url) click to toggle source
# File lib/talkshow/queue.rb, line 8
def initialize(url)
  @uri = URI.parse(url)
  @http = Net::HTTP.new(@uri.host, @uri.port)
end

Public Instance Methods

clear() click to toggle source
# File lib/talkshow/queue.rb, line 13
def clear
  response = @http.request(Net::HTTP::Get.new('/answerqueue/clear'))
  response
end
pop(ignored) click to toggle source
# File lib/talkshow/queue.rb, line 18
def pop(ignored)
  response = @http.request(Net::HTTP::Get.new('/answerqueue/pop'))
  object = JSON.parse(response.body, :symbolize_names => true)
  object[:message]
end
push(obj) click to toggle source
# File lib/talkshow/queue.rb, line 24
def push(obj)
  serialized_object = obj.to_json.to_s
  request = Net::HTTP::Post.new('/questionqueue/push')
  request.set_form_data( {'message' => serialized_object } )
  response = @http.request(request)
  nil
end