tavii / SQSJobQueueBundle

use Symfony\Component\Console\Output\OutputInterface;

use Tavii\SQSJobQueue\Queue\QueueName;

class WorkerStartCommand extends ContainerAwareCommand

{

    protected function configure()

    {

        $this->setName('sqs_job_queue:worker-start')

            ->setDescription('Start a sqs worker')

            ->addArgument('queue', InputArgument::REQUIRED, 'Queue name')

            ->addOption('sleep', 'S', InputOption::VALUE_OPTIONAL, 'sleep time', 5)

            ->addOption('foreground', 'f', InputOption::VALUE_NONE, 'Should the worker run in foreground')

        ;

    }

    protected function execute(InputInterface $input, OutputInterface $output)

    {

        $queueName = new QueueName($input->getArgument('queue'), $this->getContainer()->getParameter('sqs_job_queue.prefix'));

        $worker = $this->getContainer()->get('sqs_job_queue.worker');

        $worker->start($queueName, $input->getOption('sleep'));

    }

}

use Symfony\Component\Console\Output\OutputInterface;

use Tavii\SQSJobQueue\Queue\QueueName;

class WorkerStopCommand extends ContainerAwareCommand

{

    protected function configure()

    {

        $this->setName('sqs_job_queue:worker-stop')

            ->setDescription('Stop a sqs worker')

            ->addArgument('queue', InputArgument::REQUIRED, 'Queue name')

            ->addOption('pid', 'p', InputOption::VALUE_OPTIONAL, 'stop pid name', null)

            ->addOption('force', 'f', InputOption::VALUE_NONE, 'force storage delete')

        ;

    }

    protected function execute(InputInterface $input, OutputInterface $output)

    {

        $queueName = new QueueName($input->getArgument('queue'), $this->getContainer()->getParameter('sqs_job_queue.prefix'));

        $worker = $this->getContainer()->get('sqs_job_queue.worker');

        $worker->stop($queueName, $input->getOption('pid'), $input->getOption('force'));

    }

}