|
Lines 96-102
while (1) {
Link Here
|
| 96 |
# It could work in a first step, but then we will want to handle job that will be created from the message received |
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}); |
97 |
my $job = Koha::BackgroundJobs->find($args->{job_id}); |
| 98 |
|
98 |
|
| 99 |
process_job( $job, $args ); |
99 |
process_job( $job, $args ) if $job and $job->status eq 'new'; |
| 100 |
$conn->ack( { frame => $frame } ); # FIXME depending on success? |
100 |
$conn->ack( { frame => $frame } ); # FIXME depending on success? |
| 101 |
|
101 |
|
| 102 |
} else { |
102 |
} else { |
| 103 |
- |
|
|