diff --git a/lib/Resque.php b/lib/Resque.php index 3ec80f7..4db088c 100644 --- a/lib/Resque.php +++ b/lib/Resque.php @@ -62,7 +62,7 @@ class Resque self::$redis = new Resque_Redis($server, self::$redisDatabase); return self::$redis; } - + /** * fork() helper method for php-resque that handles issues PHP socket * and phpredis have with passing around sockets between child/parent diff --git a/lib/Resque/Job.php b/lib/Resque/Job.php index 63cb203..ddc37d0 100755 --- a/lib/Resque/Job.php +++ b/lib/Resque/Job.php @@ -58,13 +58,11 @@ class Resque_Job ); } $id = md5(uniqid('', true)); - if (!Resque::push($queue, array( + Resque::push($queue, array( 'class' => $class, 'args' => array($args), 'id' => $id, - ))) { - return false; - } + )); if($monitor) { Resque_Job_Status::create($id);