Client for Disque, an in-memory, distributed job queue.
Create a new Disque client by passing a list of nodes:
client = .(["127.0.0.1:7711", "127.0.0.1:7712", "127.0.0.1:7713"])
Now you can add jobs:
client.push("foo", "bar", 100)
It will push the job "bar" to the queue "foo" with a timeout of 100 ms, and return the id of the job if it was received and replicated in time.
Then, your workers will do something like this:
loop do client.fetch(from: ["foo"]) do |job| # Do something with `job` end end
You can install it using rubygems.
$ gem install disque