queued-ruby

Queued client for Ruby

Example

require 'queued-ruby'

client = Queued::Client.new('http://localhost:5353', auth: 'secret')
queue = client.queue('testing')

Producer:

item = queue.enqueue(foo: 'bar')

Consumer:

item = queue.dequeue(timeout: 10, wait: 30)
if item
  p item.value
  item.complete
end

Install

gem install queued-ruby