diff --git a/src/Illuminate/Queue/Events/QueueFailedOver.php b/src/Illuminate/Queue/Events/QueueFailedOver.php index bf9ad63c6ac1..b42f8c988446 100644 --- a/src/Illuminate/Queue/Events/QueueFailedOver.php +++ b/src/Illuminate/Queue/Events/QueueFailedOver.php @@ -2,6 +2,8 @@ namespace Illuminate\Queue\Events; +use Throwable; + class QueueFailedOver { /** @@ -13,6 +15,7 @@ class QueueFailedOver public function __construct( public ?string $connectionName, public mixed $command, + public Throwable $exception, ) { } } diff --git a/src/Illuminate/Queue/FailoverQueue.php b/src/Illuminate/Queue/FailoverQueue.php index 0a5c6cf9d033..3e6fd9ae64b8 100644 --- a/src/Illuminate/Queue/FailoverQueue.php +++ b/src/Illuminate/Queue/FailoverQueue.php @@ -95,7 +95,7 @@ public function push($job, $data = '', $queue = null) } catch (Throwable $e) { $lastException = $e; - $this->events->dispatch(new QueueFailedOver($connection, $job)); + $this->events->dispatch(new QueueFailedOver($connection, $job, $e)); } } @@ -143,7 +143,7 @@ public function later($delay, $job, $data = '', $queue = null) } catch (Throwable $e) { $lastException = $e; - $this->events->dispatch(new QueueFailedOver($connection, $job)); + $this->events->dispatch(new QueueFailedOver($connection, $job, $e)); } }