From 80947a4889fa348f0d319695a9bd8b3ca5e1f430 Mon Sep 17 00:00:00 2001 From: hackerESQ Date: Thu, 17 Mar 2022 19:10:30 -0500 Subject: [PATCH] adds error catching to handle method --- src/JobPipeline.php | 14 +++++++++++++- 1 file changed, 13 insertions(+), 1 deletion(-) diff --git a/src/JobPipeline.php b/src/JobPipeline.php index 0ceaa17..bf53218 100644 --- a/src/JobPipeline.php +++ b/src/JobPipeline.php @@ -5,6 +5,7 @@ declare(strict_types=1); namespace Stancl\JobPipeline; use Closure; +use Throwable; use Illuminate\Contracts\Queue\ShouldQueue; class JobPipeline implements ShouldQueue @@ -63,7 +64,18 @@ class JobPipeline implements ShouldQueue $job = [new $job(...$this->passable), 'handle']; } - $result = app()->call($job); + try { + $result = app()->call($job); + } catch(Throwable $exception) { + if ( method_exists(get_class($job[0]), 'failed') ) { + + call_user_func_array([$job[0], 'failed'], [$exception]); + } else { + Log::error($exception); + } + + break; + } if ($result === false) { break;