notify observer

Author: bytestream

src/Illuminate/Queue/Jobs/Job.php

@@ -223,6 +223,7 @@ public function fail($e = null)
             $event = new JobFailed($this->connectionName, $this, $e ?: new ManuallyFailedException);
             if ($this->observer) {
                 $event->attach($this->observer);
+                $event->notify();
             }
 
             $this->resolve(Dispatcher::class)->dispatch($event);

src/Illuminate/Queue/Worker.php

@@ -499,6 +499,7 @@ protected function handleJobException($connectionName, $job, WorkerOptions $opti
                 $event = new JobReleasedAfterException($connectionName, $job);
                 if ($this->observer) {
                     $event->attach($this->observer);
+                    $event->notify();
                 }
 
                 $this->events->dispatch($event);
@@ -671,12 +672,13 @@ protected function raiseAfterJobPopEvent($connectionName, $job)
      */
     protected function raiseBeforeJobEvent($connectionName, $job)
     {
-        $jobProcessing = new JobProcessing($connectionName, $job);
+        $event = new JobProcessing($connectionName, $job);
         if ($this->observer) {
-            $jobProcessing->attach($this->observer);
+            $event->attach($this->observer);
+            $event->notify();
         }
 
-        $this->events->dispatch($jobProcessing);
+        $this->events->dispatch($event);
     }
 
     /**
@@ -691,6 +693,7 @@ protected function raiseAfterJobEvent($connectionName, $job)
         $event = new JobProcessed($connectionName, $job);
         if ($this->observer) {
             $event->attach($this->observer);
+            $event->notify();
         }
 
         $this->events->dispatch($event);