heristop / HeriJobQueueBundle

use Heri\Bundle\JobQueueBundle\Tests\TestCase;

use Heri\Bundle\JobQueueBundle\Command\QueueFlushCommand;

class QueueFlushCommandTest extends TestCase

{

    public function testExecute()

    {

        $application = new Application($this->kernel);

        $application->add(new QueueFlushCommand());

        $command = $application->find('jobqueue:flush');

        $commandTester = new CommandTester($command);

        $commandTester->execute(array('command' => $command->getName()));

        $this->assertRegExp('/Cleaned exceptions/', $commandTester->getDisplay());

    }

}

use Heri\Bundle\JobQueueBundle\Tests\TestCase;

use Heri\Bundle\JobQueueBundle\Command\QueueWorkCommand;

class QueueListenCommandTest extends TestCase

{

    public function testExecute()

    {

        $application = new Application($this->kernel);

        $application->add(new QueueWorkCommand());

        $command = $application->find('jobqueue:work');

        $commandTester = new CommandTester($command);

        $commandTester->execute(array('command' => $command->getName()));

        $this->assertRegExp('/Handling the first job on the queue.../', $commandTester->getDisplay());

    }

}

use Heri\Bundle\JobQueueBundle\Tests\TestCase;

use Heri\Bundle\JobQueueBundle\Command\QueueShowCommand;

class QueueShowCommandTest extends TestCase

{

    public function testExecute()

    {

        $application = new Application($this->kernel);

        $application->add(new QueueShowCommand());

        $command = $application->find('jobqueue:show');

        $commandTester = new CommandTester($command);

        $commandTester->execute(array(

            'command' => $command->getName(),

            'queue-name' => 'toto',

        ));

        $this->assertRegExp('/| id | body | created | ended | failed |/', $commandTester->getDisplay());

    }

}