idanoo/laravel-resque
1
0
Fork 0
mirror of https://github.com/idanoo/laravel-resque.git synced 2024-11-24 17:35:19 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

fix detect duplicate job

Browse Source
This commit is contained in:
Holger Reinhardt 2016-07-29 15:02:27 +02:00
parent e230e66b48
commit 0663765b47
4 changed files with 14 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
config/resque.php
View File

@ -10,8 +10,7 @@ return [
*/ */
'connection' => [ 'connection' => [
'host' => env('RESQUE_REDIS_HOST', 'localhost'), 'server' => env('RESQUE_REDIS_SERVER', 'localhost:6379'),
'port' => env('RESQUE_REDIS_PORT', 6379),
'db' => env('RESQUE_REDIS_DB', 0), 'db' => env('RESQUE_REDIS_DB', 0),
], ],

5
src/Console/WorkCommand.php
View File

@ -76,8 +76,11 @@ class WorkCommand extends IlluminateCommand
*/ */
private function startWorker(array $queues, $interval = 5, $logLevel = Resque_Worker::LOG_NONE) private function startWorker(array $queues, $interval = 5, $logLevel = Resque_Worker::LOG_NONE)
{ {
$worker = $this->manager->startWorker($queues, $interval, $logLevel); $worker = new Resque_Worker($queues);
$worker->logLevel = $logLevel;
$this->info(sprintf('Starting worker %s', $worker)); $this->info(sprintf('Starting worker %s', $worker));
$worker->work($interval);
} }
/** /**

22
src/ResqueManager.php
View File

@ -62,10 +62,8 @@ class ResqueManager
$queue = new Queue($job->queue()); $queue = new Queue($job->queue());
foreach ($queue->jobs() as $queuedJob) { foreach ($queue->jobs() as $queuedJob) {
if ($job->payload['class'] === get_class($queuedJob) && count(array_intersect($queuedJob->getArguments(), if (true === $this->isDuplicateJob($job, $queuedJob)) {
$job->arguments())) === $job->arguments() return ($trackStatus) ? new \Resque_Job_Status($queuedJob->payload['id']) : null;
) {
return ($trackStatus) ? new \Resque_Job_Status($job->payload['id']) : null;
} }
} }
@ -100,18 +98,14 @@ class ResqueManager
} }
/** /**
* @param array $queues * @param \Hlgrrnhrdt\Resque\Job $job
* @param int $interval * @param $queuedJob
* @param int $logLevel
* *
* @return \Resque_Worker * @return bool
*/ */
public function startWorker(array $queues, $interval = 5, $logLevel = Resque_Worker::LOG_NONE) private function isDuplicateJob(Job $job, \Resque_Job $queuedJob)
{ {
$worker = new Resque_Worker($queues); return $queuedJob->payload['class'] === get_class($queuedJob)
$worker->logLevel = $logLevel; && count(array_intersect($queuedJob->getArguments(), $job->arguments())) === count($job->arguments());
$worker->work($interval);
return $worker;
} }
} }

2
src/ResqueServiceProvider.php
View File

@ -29,7 +29,7 @@ class ResqueServiceProvider extends ServiceProvider
$config = $this->app['config']['resque.connection']; $config = $this->app['config']['resque.connection'];
$resque = new Resque(); $resque = new Resque();
$resque->setBackend(implode(':', [$config['host'], $config['port']]), $config['db']); $resque->setBackend($config['server'], $config['db']);
return new ResqueManager($resque, $this->app['config']['resque.trackStatus']); return new ResqueManager($resque, $this->app['config']['resque.trackStatus']);
}); });