Class: Queued::Queue
- Inherits:
-
Object
- Object
- Queued::Queue
- Defined in:
- lib/queued/queue.rb
Instance Method Summary collapse
- #dequeue(params = {}) ⇒ Object
- #enqueue(value, type = 'text/plain') ⇒ Object
-
#initialize(client, name) ⇒ Queue
constructor
A new instance of Queue.
Constructor Details
#initialize(client, name) ⇒ Queue
Returns a new instance of Queue.
3 4 5 6 |
# File 'lib/queued/queue.rb', line 3 def initialize(client, name) @client = client @name = name end |
Instance Method Details
#dequeue(params = {}) ⇒ Object
21 22 23 24 25 26 27 28 29 30 31 32 33 34 |
# 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') ⇒ Object
8 9 10 11 12 13 14 15 16 17 18 19 |
# 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 |