优化

top-think · Feb 28, 2017 · 07480c3 · 07480c3
1 parent 185abd3
commit 07480c3
Showing 1 changed file with 7 additions and 3 deletions.
diff --git a/src/queue/Worker.php b/src/queue/Worker.php
@@ -92,9 +92,13 @@ public function process(Job $job, $maxTries = 0, $delay = 0)
      */
     protected function logFailedJob(Job $job)
     {
-        if (Hook::listen('queue.failed', $job, null, true)) {
-            $job->delete();
-            $job->failed();
+        if (!$job->isDeleted()) {
+            try {
+                $job->delete();
+                $job->failed();
+            } finally {
+                Hook::listen('queue.failed', $job);
+            }
         }
 
         return ['job' => $job, 'failed' => true];