feat: add fail on timeout to queue listener

laravel · Mar 3, 2024 · 43792d7 · 43792d7
1 parent 119a3a3
commit 43792d7
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 0 deletions.
diff --git a/src/Illuminate/Events/CallQueuedListener.php b/src/Illuminate/Events/CallQueuedListener.php
@@ -75,6 +75,13 @@ class CallQueuedListener implements ShouldQueue
      */
     public $shouldBeEncrypted = false;
 
+    /**
+     * Indicates if the job should fail if the timeout is exceeded.
+     *
+     * @var bool
+     */
+    public $failOnTimeout = false;
+
     /**
      * Create a new job instance.
      *

diff --git a/src/Illuminate/Events/Dispatcher.php b/src/Illuminate/Events/Dispatcher.php
@@ -675,6 +675,7 @@ protected function propagateListenerOptions($listener, $job)
             $job->shouldBeEncrypted = $listener instanceof ShouldBeEncrypted;
             $job->timeout = $listener->timeout ?? null;
             $job->tries = $listener->tries ?? null;
+            $job->failOnTimeout = $listener->failOnTimeout ?? false;
 
             $job->through(array_merge(
                 method_exists($listener, 'middleware') ? $listener->middleware(...$data) : [],