forked from wallabag/wallabag
Rename wallabag_core to wallabag
This commit is contained in:
@ -40,13 +40,13 @@ class RedisWorkerCommand extends Command
|
||||
|
||||
$serviceName = $input->getArgument('serviceName');
|
||||
|
||||
if (!$this->container->has('wallabag_core.queue.redis.' . $serviceName) || !$this->container->has('wallabag_core.consumer.redis.' . $serviceName)) {
|
||||
if (!$this->container->has('wallabag.queue.redis.' . $serviceName) || !$this->container->has('wallabag.consumer.redis.' . $serviceName)) {
|
||||
throw new Exception(sprintf('No queue or consumer found for service name: "%s"', $input->getArgument('serviceName')));
|
||||
}
|
||||
|
||||
$worker = new QueueWorker(
|
||||
$this->container->get('wallabag_core.queue.redis.' . $serviceName),
|
||||
$this->container->get('wallabag_core.consumer.redis.' . $serviceName),
|
||||
$this->container->get('wallabag.queue.redis.' . $serviceName),
|
||||
$this->container->get('wallabag.consumer.redis.' . $serviceName),
|
||||
(int) $input->getOption('maxIterations')
|
||||
);
|
||||
|
||||
|
||||
Reference in New Issue
Block a user