Lines 100-107
while (1) {
Link Here
|
100 |
# It could work in a first step, but then we will want to handle job that will be created from the message received |
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}); |
101 |
my $job = Koha::BackgroundJobs->find($args->{job_id}); |
102 |
|
102 |
|
|
|
103 |
$conn->ack( { frame => $frame } ); # Acknowledge the message was received |
103 |
process_job( $job, $args ); |
104 |
process_job( $job, $args ); |
104 |
$conn->ack( { frame => $frame } ); # FIXME depending on success? |
|
|
105 |
|
105 |
|
106 |
} else { |
106 |
} else { |
107 |
my $jobs = Koha::BackgroundJobs->search({ status => 'new', queue => \@queues }); |
107 |
my $jobs = Koha::BackgroundJobs->search({ status => 'new', queue => \@queues }); |
108 |
- |
|
|