add methods for determining if job has failed.

src/Illuminate/Queue/FailingJob.php

@@ -18,6 +18,8 @@ class FailingJob
      */
     public static function handle($connectionName, $job, $e = null)
     {
+        $job->markAsFailed();
+
         if ($job->isDeleted()) {
             return;
         }

src/Illuminate/Queue/Jobs/Job.php

@@ -36,6 +36,13 @@ abstract class Job
      */
     protected $released = false;
 
+    /**
+     * Indicates if the job has failed.
+     *
+     * @var bool
+     */
+    protected $failed = false;
+
     /**
      * The name of the connection the job belongs to.
      */
@@ -113,6 +120,26 @@ public function isDeletedOrReleased()
         return $this->isDeleted() || $this->isReleased();
     }
 
+    /**
+     * Determine if the job has been marked as a failure.
+     *
+     * @return bool
+     */
+    public function hasFailed()
+    {
+        return $this->failed;
+    }
+
+    /**
+     * Mark the job as "failed".
+     *
+     * @return void
+     */
+    public function markAsFailed()
+    {
+        $this->failed = true;
+    }
+
     /**
      * Process an exception that caused the job to fail.
      *
@@ -121,6 +148,8 @@ public function isDeletedOrReleased()
      */
     public function failed($e)
     {
+        $this->markAsFailed();
+
         $payload = $this->payload();
 
         list($class, $method) = JobName::parse($payload['job']);

tests/Queue/QueueWorkerTest.php

@@ -304,6 +304,11 @@ public function attempts()
         return $this->attempts;
     }
 
+    public function markAsFailed()
+    {
+        //
+    }
+
     public function failed($e)
     {
         $this->failedWith = $e;
@@ -313,23 +318,4 @@ public function setConnectionName($name)
     {
         $this->connectionName = $name;
     }
-
-    public function testJobSleepsWhenAnExceptionIsThrownForADaemonWorker()
-    {
-        $exceptionHandler = m::mock('Illuminate\Contracts\Debug\ExceptionHandler');
-        $job = m::mock('Illuminate\Contracts\Queue\Job');
-        $job->shouldReceive('fire')->once()->andReturnUsing(function () {
-            throw new RuntimeException;
-        });
-        $worker = m::mock('Illuminate\Queue\Worker', [$manager = m::mock('Illuminate\Queue\QueueManager')])->makePartial();
-        $manager->shouldReceive('connection')->once()->with('connection')->andReturn($connection = m::mock('StdClass'));
-        $manager->shouldReceive('getName')->andReturn('connection');
-        $connection->shouldReceive('pop')->once()->with('queue')->andReturn($job);
-        $worker->shouldReceive('sleep')->once()->with(3);
-
-        $exceptionHandler->shouldReceive('report')->once();
-
-        $worker->setDaemonExceptionHandler($exceptionHandler);
-        $worker->pop('connection', 'queue');
-    }
 }