|
Lines 78-84
if ( $conn ) {
Link Here
|
| 78 |
# FIXME cf note in Koha::BackgroundJob about $namespace |
78 |
# FIXME cf note in Koha::BackgroundJob about $namespace |
| 79 |
my $namespace = C4::Context->config('memcached_namespace'); |
79 |
my $namespace = C4::Context->config('memcached_namespace'); |
| 80 |
for my $queue (@queues) { |
80 |
for my $queue (@queues) { |
| 81 |
$conn->subscribe({ destination => sprintf("/queue/%s-%s", $namespace, $queue), ack => 'client' }); |
81 |
$conn->subscribe({ |
|
|
82 |
destination => sprintf("/queue/%s-%s", $namespace, $queue), |
| 83 |
ack => 'client', |
| 84 |
'prefetch-count' => 1, |
| 85 |
}); |
| 82 |
} |
86 |
} |
| 83 |
} |
87 |
} |
| 84 |
while (1) { |
88 |
while (1) { |
| 85 |
- |
|
|