diff --git a/lib/Alchemy/Phrasea/WorkerManager/Command/WorkerExecuteCommand.php b/lib/Alchemy/Phrasea/WorkerManager/Command/WorkerExecuteCommand.php index 70e7b41f05..8fde255710 100644 --- a/lib/Alchemy/Phrasea/WorkerManager/Command/WorkerExecuteCommand.php +++ b/lib/Alchemy/Phrasea/WorkerManager/Command/WorkerExecuteCommand.php @@ -23,9 +23,9 @@ class WorkerExecuteCommand extends Command $this->setDescription('Listen queues define on configuration, launch corresponding service for execution') ->addOption('preserve-payload', 'p', InputOption::VALUE_NONE, 'Preserve temporary payload file') ->addOption('queue-name', '', InputOption::VALUE_REQUIRED | InputOption::VALUE_IS_ARRAY, 'The name of queues to be consuming') - ->addOption('max-processes', 'm', InputOption::VALUE_REQUIRED, 'The max number of process allow to run (default 4) ') - ->addOption('MWG', '', InputOption::VALUE_NONE, 'Enable MWG metadata compatibility (use only for write metadata service)') - ->addOption('clear-metadatas', '', InputOption::VALUE_NONE, 'Delete metadatas from documents if not compliant with Database structure (use only for write metadata service)') + ->addOption('max-processes', 'm', InputOption::VALUE_REQUIRED, 'The max number of process allow to run (default 1) ') +// ->addOption('MWG', '', InputOption::VALUE_NONE, 'Enable MWG metadata compatibility (use only for write metadata service)') +// ->addOption('clear-metadatas', '', InputOption::VALUE_NONE, 'Remove metadatas from documents if not compliant with Database structure (use only for write metadata service)') ->setHelp(''); return $this; @@ -33,9 +33,6 @@ class WorkerExecuteCommand extends Command protected function doExecute(InputInterface $input, OutputInterface $output) { - $MWG = false; - $clearMetadatas = false; - $argQueueName = $input->getOption('queue-name'); $maxProcesses = intval($input->getOption('max-processes')); @@ -64,14 +61,6 @@ class WorkerExecuteCommand extends Command $workerInvoker->setMaxProcessPoolValue($maxProcesses); } - if ($input->getOption('MWG')) { - $MWG = true; - } - - if ($input->getOption('clear-metadatas')) { - $clearMetadatas = true; - } - if ($input->getOption('preserve-payload')) { $workerInvoker->preservePayloads(); } diff --git a/lib/Alchemy/Phrasea/WorkerManager/Worker/ProcessPool.php b/lib/Alchemy/Phrasea/WorkerManager/Worker/ProcessPool.php index 81917d3e56..d6586b089f 100644 --- a/lib/Alchemy/Phrasea/WorkerManager/Worker/ProcessPool.php +++ b/lib/Alchemy/Phrasea/WorkerManager/Worker/ProcessPool.php @@ -10,7 +10,7 @@ use Symfony\Component\Process\ProcessBuilder; class ProcessPool implements LoggerAwareInterface { - const MAX_PROCESSES = 4; + const MAX_PROCESSES = 1; /** * @var int @@ -41,7 +41,7 @@ class ProcessPool implements LoggerAwareInterface * Sets a logger instance on the object * * @param LoggerInterface $logger - * @return null + * @return void */ public function setLogger(LoggerInterface $logger) {