| | <?php |
| |
|
| | namespace Kanboard\Console; |
| |
|
| | use Kanboard\Core\Queue\JobHandler; |
| | use SimpleQueue\Job; |
| | use Symfony\Component\Console\Input\InputInterface; |
| | use Symfony\Component\Console\Output\OutputInterface; |
| |
|
| | |
| | |
| | |
| | |
| | |
| | |
| | class JobCommand extends BaseCommand |
| | { |
| | protected function configure() |
| | { |
| | $this |
| | ->setName('job') |
| | ->setDescription('Execute individual job (read payload from stdin)') |
| | ; |
| | } |
| |
|
| | protected function execute(InputInterface $input, OutputInterface $output): int |
| | { |
| | $payload = fgets(STDIN); |
| |
|
| | $job = new Job(); |
| | $job->unserialize($payload); |
| |
|
| | JobHandler::getInstance($this->container)->executeJob($job); |
| | return 0; |
| | } |
| | } |
| |
|