Fixes laravel#19072

iget-esoares · iget-esoares · commit ddf6d4a2ff47 · 2017-05-05T17:14:23.000-03:00
diff --git a/src/Illuminate/Queue/Worker.php b/src/Illuminate/Queue/Worker.php
@@ -3,6 +3,8 @@
 namespace Illuminate\Queue;
 
 use Exception;
+use Illuminate\Database\DetectsLostConnections;
+use PDOException;
 use Throwable;
 use Illuminate\Contracts\Events\Dispatcher;
 use Illuminate\Contracts\Debug\ExceptionHandler;
@@ -11,6 +13,8 @@
 
 class Worker
 {
+    use DetectsLostConnections;
+    
     /**
      * The queue manager instance.
      *
@@ -233,10 +237,14 @@ protected function getNextJob($connection, $queue)
     {
         try {
             foreach (explode(',', $queue) as $queue) {
-                if (! is_null($job = $connection->pop($queue))) {
+                if (!is_null($job = $connection->pop($queue))) {
                     return $job;
                 }
             }
+        } catch (PDOException $e) {
+            if ($this->causedByLostConnection($e)) {
+                $this->stop(1);
+            }
         } catch (Exception $e) {
             $this->exceptions->report($e);
         } catch (Throwable $e) {
