Skip to content

Commit c090cb8

Browse files
committed
Fix integration test.
1 parent a0f28c3 commit c090cb8

2 files changed

Lines changed: 3 additions & 3 deletions

File tree

src/Command/WorkerCommand.php

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -24,6 +24,7 @@
2424
use Cake\Log\Log;
2525
use Cake\Queue\Consumption\QueueExtension;
2626
use Cake\Queue\Queue\Processor;
27+
use Cake\Queue\QueueManager;
2728
use Enqueue\SimpleClient\SimpleClient;
2829
use Psr\Log\LoggerInterface;
2930
use Psr\Log\NullLogger;
@@ -139,8 +140,7 @@ public function execute(Arguments $args, ConsoleIo $io)
139140
$processor->getEventManager()->on($listener);
140141
$extension->getEventManager()->on($listener);
141142
}
142-
$url = Configure::read("Queue.{$config}.url");
143-
$client = new SimpleClient($url, $logger);
143+
$client = QueueManager::engine($config);
144144
$queue = $args->getOption('queue')
145145
? (string)$args->getOption('queue')
146146
: Configure::read("Queue.{$config}.queue", 'default');

tests/TestCase/Command/WorkerCommandTest.php

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -223,7 +223,7 @@ public function testQueueProcessesJobWithOtherQueue()
223223
{
224224
$config = [
225225
'queue' => 'other',
226-
'url' => 'file:///' . TMP . DS . 'queue',
226+
'url' => 'file:///' . TMP . DS . 'other-queue',
227227
];
228228
Configure::write([
229229
'Queue' => ['other' => $config],

0 commit comments

Comments
 (0)