class Queued::Queue
Public Class Methods
new(client, name)
click to toggle source
# File lib/queued/queue.rb, line 3 def initialize(client, name) @client = client @name = name end
Public Instance Methods
dequeue(params = {})
click to toggle source
# File lib/queued/queue.rb, line 21 def dequeue(params = {}) res = @client.post do |req| req.url "/#{@name}/dequeue" req.params[:wait] = params[:wait] if params[:wait] req.params[:timeout] = params[:timeout] if params[:timeout] end return nil if res.status === 404 Item.new(@client, value: res.body, type: res.headers['Content-Type'], url: res.headers['Location']) end
enqueue(value, type = 'text/plain')
click to toggle source
# File lib/queued/queue.rb, line 8 def enqueue(value, type = 'text/plain') res = @client.post do |req| req.url "/#{@name}" req.headers['Content-Type'] = type req.body = value end Item.new(@client, value: value, type: type, url: res.headers['Location']) end