idanoo/php-resque
1
0
Fork 0
mirror of https://github.com/idanoo/php-resque.git synced 2024-11-22 08:15:14 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Merge pull request #107 from danhunsaker/feature-queue-failure

Browse Source 
Added enqueue failure detection
This commit is contained in:
Chris Boulton 2013-05-28 18:19:01 -07:00
commit 37cdec8e11
2 changed files with 9 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
lib/Resque.php
View File

@ -98,7 +98,11 @@ class Resque
public static function push($queue, $item) public static function push($queue, $item)
{ {
self::redis()->sadd('queues', $queue); self::redis()->sadd('queues', $queue);
self::redis()->rpush('queue:' . $queue, json_encode($item)); $length = self::redis()->rpush('queue:' . $queue, json_encode($item));
if ($length < 1) {
return false;
}
return true;
} }
/** /**

6
lib/Resque/Job.php
View File

@ -58,11 +58,13 @@ class Resque_Job
); );
} }
$id = md5(uniqid('', true)); $id = md5(uniqid('', true));
Resque::push($queue, array( if (!Resque::push($queue, array(
'class' => $class, 'class' => $class,
'args' => array($args), 'args' => array($args),
'id' => $id, 'id' => $id,
)); ))) {
return false;
}
if($monitor) { if($monitor) {
Resque_Job_Status::create($id); Resque_Job_Status::create($id);