View | Details | Raw Unified | Return to bug 22417
Collapse All | Expand All

(-)a/Koha/BackgroundJob.pm (-1 / +1 lines)
Lines 55-61 sub enqueue { Link Here
55 
            # Also, here we just want the Koha instance's name, but it's not in the config...
 55 
            # Also, here we just want the Koha instance's name, but it's not in the config...
56 
            # Picking a random id (memcached_namespace) from the config
 56 
            # Picking a random id (memcached_namespace) from the config
57 
            my $namespace = C4::Context->config('memcached_namespace');
 57 
            my $namespace = C4::Context->config('memcached_namespace');
58 
            $conn->send_with_receipt( { destination => sprintf("%s-%s", $namespace, $job_type), body => $json_args } )
 58 
            $conn->send_with_receipt( { destination => sprintf("/queue/%s-%s", $namespace, $job_type), body => $json_args } )
59 
              or Koha::Exceptions::Exception->throw('Job has not been enqueued');
 59 
              or Koha::Exceptions::Exception->throw('Job has not been enqueued');
60 
        }
 60 
        }
61 
    );
 61 
    );
(-)a/misc/background_jobs_worker.pl (-2 / +1 lines)
Lines 27-33 my @job_types = qw( batch_biblio_record_modification batch_authority_record_modi Link Here
27 
# FIXME cf note in Koha::BackgroundJob about $namespace
 27 
# FIXME cf note in Koha::BackgroundJob about $namespace
28 
my $namespace = C4::Context->config('memcached_namespace');
 28 
my $namespace = C4::Context->config('memcached_namespace');
29 
for my $job_type ( @job_types ) {
 29 
for my $job_type ( @job_types ) {
30 
    $conn->subscribe({ destination => sprintf("%s-%s", $namespace, $job_type), ack => 'client' });
 30 
    $conn->subscribe({ destination => sprintf("/queue/%s-%s", $namespace, $job_type), ack => 'client' });
31 
}
 31 
}
32 
while (1) {
 32 
while (1) {
33 
    my $frame = $conn->receive_frame;
 33 
    my $frame = $conn->receive_frame;
34 
-

Return to bug 22417