framework/tests/Queue/QueueListenerTest.php at master · JavaDevl/framework · GitHub

History

executable file

44 lines (36 loc) · 1.69 KB

Raw

<?php

use Mockery as m;

class QueueListenerTest extends PHPUnit_Framework_TestCase

{

public function tearDown()

{

m::close();

}

public function testRunProcessCallsProcess()

{

$process = m::mock('Symfony\Component\Process\Process')->makePartial();

$process->shouldReceive('run')->once();

$listener = m::mock('Illuminate\Queue\Listener')->makePartial();

$listener->shouldReceive('memoryExceeded')->once()->with(1)->andReturn(false);

$listener->runProcess($process, 1);

}

public function testListenerStopsWhenMemoryIsExceeded()

{

$process = m::mock('Symfony\Component\Process\Process')->makePartial();

$process->shouldReceive('run')->once();

$listener = m::mock('Illuminate\Queue\Listener')->makePartial();

$listener->shouldReceive('memoryExceeded')->once()->with(1)->andReturn(true);

$listener->shouldReceive('stop')->once();

$listener->runProcess($process, 1);

}

public function testMakeProcessCorrectlyFormatsCommandLine()

{

$listener = new Illuminate\Queue\Listener(__DIR__);

$process = $listener->makeProcess('connection', 'queue', 1, 2, 3);

$escape = '\\' === DIRECTORY_SEPARATOR ? '"' : '\'';

$this->assertInstanceOf('Symfony\Component\Process\Process', $process);

$this->assertEquals(__DIR__, $process->getWorkingDirectory());

$this->assertEquals(3, $process->getTimeout());

$this->assertEquals($escape.PHP_BINARY.$escape.(defined('HHVM_VERSION') ? ' --php' : '')." artisan queue:work {$escape}connection{$escape} --queue={$escape}queue{$escape} --delay=1 --memory=2 --sleep=3 --tries=0", $process->getCommandLine());

}

framework/tests/Queue/QueueListenerTest.php at master · JavaDevl/framework · GitHub

Expand file tree

Breadcrumbs

QueueListenerTest.php

Latest commit

History

Breadcrumbs

QueueListenerTest.php

File metadata and controls