3 # This file is part of Koha.
5 # Koha is free software; you can redistribute it and/or modify it
6 # under the terms of the GNU General Public License as published by
7 # the Free Software Foundation; either version 3 of the License, or
8 # (at your option) any later version.
10 # Koha is distributed in the hope that it will be useful, but
11 # WITHOUT ANY WARRANTY; without even the implied warranty of
12 # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
13 # GNU General Public License for more details.
15 # You should have received a copy of the GNU General Public License
16 # along with Koha; if not, see <http://www.gnu.org/licenses>.
20 background_jobs_worker.pl - Worker script that will process background jobs
24 ./background_jobs_worker.pl [--queue QUEUE]
28 This script will connect to the Stomp server (RabbitMQ) and subscribe to the queues passed in parameter (or the 'default' queue),
29 or if a Stomp server is not active it will poll the database every 10s for new jobs in the passed queue.
31 You can specify some queues only (using --queue, which is repeatable) if you want to run several workers that will handle their own jobs.
39 Repeatable. Give the job queues this worker will process.
41 The different values available are:
51 use JSON qw( decode_json );
52 use Try::Tiny qw( catch try );
56 use Koha::BackgroundJobs;
58 my ( $help, @queues );
61 'queue=s' => \@queues,
64 pod2usage(0) if $help;
67 push @queues, 'default';
72 $conn = Koha::BackgroundJob->connect;
74 warn sprintf "Cannot connect to the message broker, the jobs will be processed anyway (%s)", $_;
78 # FIXME cf note in Koha::BackgroundJob about $namespace
79 my $namespace = C4::Context->config('memcached_namespace');
80 for my $queue (@queues) {
82 destination => sprintf("/queue/%s-%s", $namespace, $queue),
84 'prefetch-count' => 1,
90 my $frame = $conn->receive_frame;
91 if ( !defined $frame ) {
92 # maybe log connection problems
93 next; # will reconnect automatically
96 my $body = $frame->body;
97 my $args = decode_json($body); # TODO Should this be from_json? Check utf8 flag.
99 # FIXME This means we need to have create the DB entry before
100 # It could work in a first step, but then we will want to handle job that will be created from the message received
101 my $job = Koha::BackgroundJobs->find($args->{job_id});
103 $conn->ack( { frame => $frame } ); # Acknowledge the message was received
104 process_job( $job, $args );
107 my $jobs = Koha::BackgroundJobs->search({ status => 'new', queue => \@queues });
108 while ( my $job = $jobs->next ) {
109 my $args = $job->json->decode($job->data);
110 process_job( $job, { job_id => $job->id, %$args } );
118 my ( $job, $args ) = @_;
126 die "fork failed!" unless defined $pid;
128 $job->process( $args );