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

Added enqueue failure detection

Author: chrisboulton

lib/Resque.php

@@ -98,7 +98,11 @@ public static function fork()
 	public static function push($queue, $item)
 	{
 		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;
 	}
 
 	/**

lib/Resque/Job.php

@@ -58,11 +58,13 @@ public static function create($queue, $class, $args = null, $monitor = false)
 			);
 		}
 		$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);