Merge pull request #63 from cakephp/tests-61

Add tests for #61

Author: othercorey

src/Command/WorkerCommand.php

@@ -24,7 +24,7 @@
 use Cake\Log\Log;
 use Cake\Queue\Consumption\QueueExtension;
 use Cake\Queue\Queue\Processor;
-use Enqueue\SimpleClient\SimpleClient;
+use Cake\Queue\QueueManager;
 use Psr\Log\LoggerInterface;
 use Psr\Log\NullLogger;
 
@@ -139,8 +139,7 @@ public function execute(Arguments $args, ConsoleIo $io)
             $processor->getEventManager()->on($listener);
             $extension->getEventManager()->on($listener);
         }
-        $url = Configure::read("Queue.{$config}.url");
-        $client = new SimpleClient($url, $logger);
+        $client = QueueManager::engine($config);
         $queue = $args->getOption('queue')
             ? (string)$args->getOption('queue')
             : Configure::read("Queue.{$config}.queue", 'default');

tests/TestCase/Command/WorkerCommandTest.php

@@ -223,7 +223,7 @@ public function testQueueProcessesJobWithOtherQueue()
     {
         $config = [
             'queue' => 'other',
-            'url' => 'file:///' . TMP . DS . 'queue',
+            'url' => 'file:///' . TMP . DS . 'other-queue',
         ];
         Configure::write([
             'Queue' => ['other' => $config],

tests/TestCase/QueueManagerTest.php

@@ -71,6 +71,33 @@ public function testSetConfigOverwrite()
         ]);
     }
 
+    public function testNonDefaultQueueNameString()
+    {
+        QueueManager::setConfig('test', [
+            'url' => 'file:///' . TMP . DS . 'queue',
+            'queue' => 'other',
+        ]);
+        $engine = QueueManager::engine('test');
+        $this->assertInstanceOf(SimpleClient::class, $engine);
+        $this->assertSame('other', $engine->getDriver()->getConfig()->getRouterQueue());
+    }
+
+    public function testNonDefaultQueueNameArray()
+    {
+        QueueManager::setConfig('test', [
+            'url' => [
+                'transport' => 'file:',
+                'client' => [
+                    'router_queue' => 'other',
+                ],
+            ],
+            'queue' => 'ignored',
+        ]);
+        $engine = QueueManager::engine('test');
+        $this->assertInstanceOf(SimpleClient::class, $engine);
+        $this->assertSame('other', $engine->getDriver()->getConfig()->getRouterQueue());
+    }
+
     public function testEngine()
     {
         QueueManager::setConfig('test', [