blob: 333d0ba4fbf49ba6127e80025f5b7494bdfa8e08 (
plain) (
tree)
|
|
package presque;
our $VERSION = '0.01';
use AnyEvent::Redis;
use Moose;
extends 'Tatsumaki::Application';
has config => (is => 'rw', isa => 'HashRef', lazy => 1, default => sub { });
has redis => (
is => 'rw',
isa => 'Object',
lazy => 1,
default => sub {
my $self = shift;
AnyEvent::Redis->new(
host => $self->config->{redis}->{host},
port => $self->config->{redis}->{port}
);
}
);
sub h {
my $class = shift;
eval "require $class" or die $@;
$class;
}
sub app {
my ($class, %args) = @_;
my $self = $class->new(
[ '/q/(.*)' => h('presque::RestQueueHandler'),
'/j/(.*)' => h('presque::JobQueueHandler'),
'/w/(.*)' => h('presque::WorkerHandler'),
'/status/(.*)' => h('presque::StatusHandler'),
'/control/(.*)' => h('presque::ControlHandler'),
'/' => h('presque::IndexHandler'),
]
);
$self->config(delete $args{config});
$self;
}
1;
__END__
=head1 NAME
presque - a redis based message queue
=head1 SYNOPSIS
=head1 DESCRIPTION
presque is a message queue system based on Tatsumaki and Redis.
The functionalities are inspired by L<RestMQ|http://github.com/gleicon/restmq> and the name by L<resque|http://github.com/defunkt/resque>.
The following HTTP routes are available:
=over 4
=item B<GET /q/queuename>
gets an object out of the queue
=item B<POST /q/queuename>
insert an object in the queue
=item B<DELETE /q/queuename>
purge and delete the queue
=item B<GET /stats/[queuename]>
return some statues about the queue. If no queue is given, return basic statues about
all the queues.
=item B<GET /j/queuename>
return some basic information about a queue.
=item B<GET /control/queuename>
return the status of the queue. A queue have two statues: open or closed. When a queue is closed, no job can be extracted from the queue.
=item B<POST /control/queuename>
change the status of the queue.
=back
=head2 INSERT A JOB
The B<Content-Type> of the request must be set to B<application/json>. The body of the request
must be a valid JSON object.
curl -H 'Content-Type: application/json' -X POST "http://localhost:5002/q/foo" -d '{"key":"value"}'
It's possible to create delayed jobs (eg: job that will not be run before a defined time in the futur).
curl -H 'Content-Type: application/json' -X POST "http://localhost:5002/q/foo?delayed="$(expr `date +%s` + 500) -d '{"key":"value"}'
the B<delayed> value should be a date in epoch
=head2 FETCH A JOB
Return a JSON object
curl http://localhost:5002/q/foo
=head2 PURGE AND DELETE A QUEUE
curl -X DELETE http://localhost:5002/q/foo
=head1 AUTHOR
franck cuny E<lt>franck@lumberjaph.netE<gt>
=head1 SEE ALSO
=head1 LICENSE
Copyright 2010 by Linkfluence
L<http://linkfluence.net>
This library is free software; you can redistribute it and/or modify
it under the same terms as Perl itself.
=cut
|
