Pass failed onto commands / event handlers.

flavorzyb · Jan 20, 2015 · 36b6063 · 36b6063
1 parent dfc4a69
commit 36b6063
Show file tree

Hide file tree

Showing 2 changed files with 30 additions and 0 deletions.
diff --git a/src/Illuminate/Events/CallQueuedHandler.php b/src/Illuminate/Events/CallQueuedHandler.php
@@ -63,4 +63,19 @@ protected function setJobInstanceIfNecessary(Job $job, $instance)
 		return $instance;
 	}
 
+	/**
+	 * Call the failed method on the job instance.
+	 *
+	 * @return void
+	 */
+	public function failed(array $data)
+	{
+		$handler = $this->container->make($data['class']);
+
+		if (method_exists($handler, 'failed'))
+		{
+			call_user_func_array([$handler, 'failed'], unserialize($data));
+		}
+	}
+
 }
diff --git a/src/Illuminate/Queue/CallQueuedHandler.php b/src/Illuminate/Queue/CallQueuedHandler.php
@@ -64,4 +64,19 @@ protected function setJobInstanceIfNecessary(Job $job, $instance)
 		return $instance;
 	}
 
+	/**
+	 * Call the failed method on the job instance.
+	 *
+	 * @return void
+	 */
+	public function failed(array $data)
+	{
+		$handler = $this->dispatcher->resolveHandler($command = unserialize($data['command']));
+
+		if (method_exists($handler, 'failed'))
+		{
+			call_user_func([$handler, 'failed'], $command);
+		}
+	}
+
 }