diff --git a/lib/Resque.php b/lib/Resque.php index fa22ed1..75b8d52 100644 --- a/lib/Resque.php +++ b/lib/Resque.php @@ -98,7 +98,11 @@ class Resque public static function push($queue, $item) { 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; } /** diff --git a/lib/Resque/Job.php b/lib/Resque/Job.php index 82b11bc..fc84e1e 100755 --- a/lib/Resque/Job.php +++ b/lib/Resque/Job.php @@ -58,11 +58,14 @@ class Resque_Job ); } $id = md5(uniqid('', true)); - Resque::push($queue, array( + if ( ! Resque::push($queue, array( 'class' => $class, 'args' => array($args), 'id' => $id, - )); + ))) + { + return FALSE; + } if($monitor) { Resque_Job_Status::create($id);