Source of file QueueManagerTest.php
Size: 2,465 Bytes - Last Modified: 2021-12-23T10:38:27+00:00
/var/www/docs.ssmods.com/process/src/tests/QueueManagerTest.php
12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182 | <?php namespace StudioBonito\SilverStripe\Queue\Tests; use Mockery as m; use StudioBonito\SilverStripe\Queue\QueueManager; class QueueManagerTest extends \PHPUnit_Framework_TestCase { public function tearDown() { m::close(); } public function testConnectionCanBePassedDirectly() { $connector = m::mock('StudioBonito\SilverStripe\Queue\Connectors\ConnectorInterface'); $manager = new QueueManager( array('sync' => $connector) ); $config = m::mock('StdClass'); $queue = m::mock('StdClass'); $config->shouldReceive('get')->once()->with('sync')->andReturn(array('driver' => 'sync')); $connector->shouldReceive('connect')->once()->with(array('driver' => 'sync'))->andReturn($queue); $manager->setConfig($config); $queue->shouldReceive('setInjector')->once(); $this->assertTrue($queue === $manager->connection('sync')); } public function testDefaultConnectionCanBeResolved() { $manager = new QueueManager(array()); $config = m::mock('StdClass'); $connector = m::mock('StdClass'); $queue = m::mock('StdClass'); $config->shouldReceive('get')->once()->with('sync')->andReturn(array('driver' => 'sync')); $connector->shouldReceive('connect')->once()->with(array('driver' => 'sync'))->andReturn($queue); $manager->setConfig($config); $manager->addConnector( 'sync', function () use ($connector) { return $connector; } ); $queue->shouldReceive('setInjector')->once(); $this->assertTrue($queue === $manager->connection('sync')); } public function testOtherConnectionCanBeResolved() { $manager = new QueueManager(array()); $config = m::mock('StdClass'); $connector = m::mock('StdClass'); $queue = m::mock('StdClass'); $config->shouldReceive('get')->once()->with('foo')->andReturn(array('driver' => 'bar')); $connector->shouldReceive('connect')->once()->with(array('driver' => 'bar'))->andReturn($queue); $manager->setConfig($config); $manager->addConnector( 'bar', function () use ($connector) { return $connector; } ); $queue->shouldReceive('setInjector')->once(); $this->assertTrue($queue === $manager->connection('foo')); } } |