queued-ruby

require 'queued-ruby'

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

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

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