Report job failures to failed jobs provider (#31)

* Report job failures to failed jobs provider * sort imports Co-authored-by: Till Krüss <[email protected]>
brefphp · Nov 21, 2022 · c12daec · c12daec
1 parent 330cbfd
commit c12daec
Showing 1 changed file with 12 additions and 1 deletion.
diff --git a/src/BrefServiceProvider.php b/src/BrefServiceProvider.php
@@ -12,9 +12,11 @@
 use Illuminate\Contracts\Http\Kernel;
 use Illuminate\Contracts\Events\Dispatcher;
 
+use Illuminate\Queue\Events\JobFailed;
 use Illuminate\Queue\Events\JobProcessed;
 use Illuminate\Queue\Events\JobProcessing;
 use Illuminate\Queue\Events\JobExceptionOccurred;
+use Illuminate\Queue\Failed\FailedJobProviderInterface;
 
 class BrefServiceProvider extends ServiceProvider
 {
@@ -67,7 +69,7 @@ public function register()
      *
      * @return void
      */
-    public function boot(Dispatcher $dispatcher, LogManager $logManager)
+    public function boot(Dispatcher $dispatcher, LogManager $logManager, FailedJobProviderInterface $queueFailer)
     {
         if ($this->app->runningInConsole()) {
             $this->publishes([
@@ -99,6 +101,15 @@ public function boot(Dispatcher $dispatcher, LogManager $logManager)
                 ['name' => $event->job->resolveName()]
             )
         );
+
+        $dispatcher->listen(
+            fn (JobFailed $event) => $queueFailer->log(
+                $event->connectionName,
+                $event->job->getQueue(),
+                $event->job->getRawBody(),
+                $event->exception
+            )
+        );
     }
 
     /**