1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
|
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/tatsumaki based message queue
=head1 SYNOPSIS
=head1 DESCRIPTION
presque is a persistent job queue that uses Redis for storage and Tatsumaki for the interface between workers and Redis.
presque implement a REST interface for communications, and jobs are JSON data structure.
Workers can be written in any language as long as they implement the REST interface. A complete worker exists for Perl L<presque::worker>. Some examples in other languages can be found in the B<eg> directory.
The functionalities are inspired by L<RestMQ|http://github.com/gleicon/restmq> and L<resque|http://github.com/defunkt/resque>.
=head2 HTTP ROUTES
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<PUT /q/queuename>
re-insert a job after a worker failed to process the job
=item B<DELETE /q/queuename>
purge and delete the queue
=item B<GET /status/>
informations about a queue.
=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.
=item B<GET /w/>
some statisctics about a worker
=item B<POST /w/queuename>
register a worker on a queue.
=item B<DELETE /w/queue_name>
unregister a worker on a queue.
=back
=head1 AUTHOR
franck cuny E<lt>franck@lumberjaph.netE<gt>
=head1 SEE ALSO
For a complete description of each routes, refer to L<presque::WorkerHandler>, L<presque::RestQueueHandler>, L<presque::ControlHandler>, L<presque::JobQueueHandler>, L<presque::StatusHandler>.
For a complete worker see L<presque::worker>.
=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
|
