heristop / HeriJobQueueBundle

use Symfony\Component\Console\Input\InputInterface;

use Symfony\Component\Console\Output\OutputInterface;

class QueueDeleteCommand extends ContainerAwareCommand

{

    /**

     * {@inheritdoc}

     */

    protected function configure()

    {

        $this

            ->setName('jobqueue:delete')

            ->setDescription('Delete a queue')

            ->addArgument('queue-name', InputArgument::REQUIRED, 'Which name do you want for the queue?')

        ;

    }

    /**

     * {@inheritdoc}

     */

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

    {

        $queue = $this->getContainer()->get('jobqueue');

        $name = $input->getArgument('queue-name');

        if ($queue->delete($name)) {

            $output->writeLn(sprintf('<info>Queue "%s" deleted</info>', $name));

        }

    }

}

use Symfony\Component\Console\Input\InputInterface;

use Symfony\Component\Console\Output\OutputInterface;

class QueueRetryCommand extends ContainerAwareCommand

{

    /**

     * {@inheritdoc}

     */

    protected function configure()

    {

        $this

            ->setName('jobqueue:retry')

            ->setDescription('Retrying Failed Jobs')

            ->addArgument('queue-name', InputArgument::REQUIRED, 'Which name do you want for the queue?')

        ;

    }

    /**

     * {@inheritdoc}

     */

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

    {

        $queue = $this->getContainer()->get('jobqueue');

        $name = $input->getArgument('queue-name');

        if ($queue->retry($name)) {

            $output->writeLn(sprintf('<info>Retried failed jobs for %s deleted</info>', $name));

        }

    }

}

use Symfony\Component\Console\Input\InputOption;

use Symfony\Component\Console\Output\OutputInterface;

class QueueForgetCommand extends ContainerAwareCommand

{

    /**

     * {@inheritdoc}

     */

    protected function configure()

    {

        $this

            ->setName('jobqueue:forget')

            ->setDescription('Retrying Failed Jobs')

            ->addOption('record', null, InputOption::VALUE_NONE, 'Id of failed message to forget');

    }

    /**

     * {@inheritdoc}

     */

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

    {

        $queue = $this->getContainer()->get('jobqueue');

        $id = $input->getOption('record');

        if ($queue->forget($id)) {

            $output->writeLn(sprintf('<info>Forgotten message %s</info>', $id));

        }

    }

}