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) {
81 $conn->subscribe({ destination => sprintf("/queue/%s-%s", $namespace, $queue), ack => 'client' });
86 my $frame = $conn->receive_frame;
87 if ( !defined $frame ) {
88 # maybe log connection problems
89 next; # will reconnect automatically
92 my $body = $frame->body;
93 my $args = decode_json($body);
95 # FIXME This means we need to have create the DB entry before
96 # It could work in a first step, but then we will want to handle job that will be created from the message received
97 my $job = Koha::BackgroundJobs->find($args->{job_id});
99 process_job( $job, $args );
100 $conn->ack( { frame => $frame } ); # FIXME depending on success?
103 my $jobs = Koha::BackgroundJobs->search({ status => 'new', queue => \@queues });
104 while ( my $job = $jobs->next ) {
105 my $args = decode_json($job->data);
106 process_job( $job, { job_id => $job->id, %$args } );
114 my ( $job, $args ) = @_;
122 die "fork failed!" unless defined $pid;
124 $job->process( $args );