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

Added enqueue failure detection

Browse Source 
If a job fails to be enqueued, it would be useful to know it.  So now
Resque actually tells us whether the enqueue action was successful or
if it failed.  If your job ID comes back as FALSE, it didn't enqueue.

Signed-off-by: Daniel Hunsaker <danhunsaker@gmail.com>
This commit is contained in:
Daniel Hunsaker 2013-05-09 16:27:50 -06:00
parent 1310b0661b
commit 3798fa3ba6
2 changed files with 10 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)); if (self::redis()->rpush('queue:' . $queue, json_encode($item)) < 1)
{
return FALSE;
}
return TRUE;
} }
/** /**

7
lib/Resque/Job.php
View File

@ -58,11 +58,14 @@ 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);