diff --git a/src/Queue/Server.php b/src/Queue/Server.php index 8e576cb..4230c22 100644 --- a/src/Queue/Server.php +++ b/src/Queue/Server.php @@ -289,6 +289,11 @@ public function start(): self Console::error("[Job] ({$message->getPid()}) failed to run."); Console::error("[Job] ({$message->getPid()}) {$th->getMessage()}"); + + self::setResource('error', fn () => $th); + foreach ($this->errorHooks as $hook) { + call_user_func_array($hook->getAction(), $this->getArguments($hook)); + } } finally { /** * Remove Job from Processing.