Skip to content

Commit 43e6a2b

Browse files
committed
TASK: Update imports in fastrabbit bin
Original: 591733d6fce4c3597d1ee36bd847cd7fdc8c3b4b
1 parent a988864 commit 43e6a2b

1 file changed

Lines changed: 8 additions & 4 deletions

File tree

bin/fast-rabbit

Lines changed: 8 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,10 @@
11
#!/usr/bin/env php
22
<?php
33

4+
use Netlogix\JobQueue\FastRabbit\Cache\CacheFactory;
5+
use Netlogix\JobQueue\FastRabbit\Lock;
6+
use Netlogix\JobQueue\FastRabbit\Loop;
7+
use Netlogix\JobQueue\FastRabbit\Worker;
48
use t3n\JobQueue\RabbitMQ\Queue\RabbitQueue;
59

610
require_once __DIR__ . '/../src/autoload.php';
@@ -17,10 +21,10 @@ $queueOptions = $queueSettings['options'];
1721
$command = $config['command'];
1822

1923
$queue = new RabbitQueue($queueName, $queueOptions);
20-
$messageCache = \Netlogix\JobQueue\FastRabbit\Cache\CacheFactory::get($config);
21-
$lock = new \Netlogix\JobQueue\FastRabbit\Lock($config['workerPool']['numberOfWorkers'], $config['workerPool']['lockFileDirectory']);
24+
$messageCache = CacheFactory::get($config);
25+
$lock = new Lock($config['workerPool']['numberOfWorkers'], $config['workerPool']['lockFileDirectory']);
2226

23-
$worker = new \Netlogix\JobQueue\FastRabbit\Worker($command, $queue, $queueSettings, $messageCache, $lock);
24-
$loop = new \Netlogix\JobQueue\FastRabbit\Loop($queue);
27+
$worker = new Worker($command, $queue, $queueSettings, $messageCache, $lock);
28+
$loop = new Loop($queue);
2529

2630
$loop->runMessagesOnWorker($worker);

0 commit comments

Comments
 (0)