Sha256: fa71f32eee813c8d16fdcda3e9113af8d67614f09db58796faafa9651dc7d066
Contents?: true
Size: 689 Bytes
Versions: 2
Compression:
Stored size: 689 Bytes
Contents
disque-rb ========= Client for Disque, an in-memory, distributed job queue. Usage ----- Create a new Disque client by passing a list of nodes: ```ruby client = Disque.new(["127.0.0.1:7711", "127.0.0.1:7712", "127.0.0.1:7713"]) ``` Now you can add jobs: ```ruby 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: ```ruby loop do client.fetch(from: ["foo"]) do |job| # Do something with `job` end end ``` Installation ------------ You can install it using rubygems. ``` $ gem install disque ```
Version data entries
2 entries across 2 versions & 1 rubygems
Version | Path |
---|---|
disque-0.0.4 | README.md |
disque-0.0.3 | README.md |