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