diff --git a/src/Illuminate/Database/DetectsLostConnections.php b/src/Illuminate/Database/DetectsLostConnections.php index bee348203f69..034fbe649f6f 100644 --- a/src/Illuminate/Database/DetectsLostConnections.php +++ b/src/Illuminate/Database/DetectsLostConnections.php @@ -28,6 +28,7 @@ protected function causedByLostConnection(Exception $e) 'SSL connection has been closed unexpectedly', 'Error writing data to the connection', 'Resource deadlock avoided', + 'Transaction() on null', ]); } } diff --git a/src/Illuminate/Queue/Worker.php b/src/Illuminate/Queue/Worker.php index 866c9da5386f..9de5796931eb 100644 --- a/src/Illuminate/Queue/Worker.php +++ b/src/Illuminate/Queue/Worker.php @@ -246,6 +246,8 @@ protected function getNextJob($connection, $queue) $this->stopWorkerIfLostConnection($e); } catch (Throwable $e) { $this->exceptions->report(new FatalThrowableError($e)); + + $this->stopWorkerIfLostConnection($e); } } @@ -267,6 +269,8 @@ protected function runJob($job, $connectionName, WorkerOptions $options) $this->stopWorkerIfLostConnection($e); } catch (Throwable $e) { $this->exceptions->report(new FatalThrowableError($e)); + + $this->stopWorkerIfLostConnection($e); } }