Perl client for Disque, an in-memory, distributed job queue

For those who want to see things working right now.

Open a new terminal and do:

$ perl examples/producer.pl

Open another terminal and do:

$ perl examples/consumer.pl

You will start seeing the new jobs arriving on the 'consumer' terminal. Also you can set up multiple instances of disque cluster and shut down some of them and you will see how the clients will automatically reconnect to any available disque server.

Connection:

perl-disque will try to connect to any available server in the order that has been set. If there is no disque instance available, the client will generate a connection error and will abort.

# Defaults to $ENV{DISQUE_SERVER} or 127.0.0.1:7711
use Disque;
my $disque = Disque->new;

To send a new job just do

$disque->add_job('test','job_1', 0);

You can use this library with single or multi-node clusters.

When you invoke "new()" you can choose which method you will use to connect to the cluster; of course, this only will happen if there is more than 1 node specified.

By default, as Salvatore specified in the doc, the lib will try to connect to any available server in a random way.

But also if you don't want to connect to the server randomly you can specify the param "disable_random_connect => 1" in new() sub, for example:

my $disque = Disque->new(
	servers => ['localhost:7711', 'localhost:7712', 'localhost:7713'],
	disable_random_connect => 1
);

Then you will connect to the cluster in the order that you have set the nodes.

You can set the global environment variable: $ export DISQUE_DEBUG=1

Or you can specify debug at connection:

my $disque = Disque->new(debug => 1);

The commands that are already available are: add_job get_job ack_job fast_ack qlen qpeek enqueue dequeue del_job show jscan qstat qscan nack

$ cpan install Disque

• Create tests
• Add more documentation in pm module

See LICENSE.

• Big thanks to Salvatore Sanfilippo aka antirez for share his work.
• The people who contributed and did perl-redis module.