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