[11.x] Add option to report throttled exception in ThrottlesExceptions middleware (#50896)

* feat: add option to report the throttled exception

* Update ThrottlesExceptions.php

---------

Co-authored-by: Taylor Otwell <taylor@laravel.com>

Author: JaZo

src/Illuminate/Queue/Middleware/ThrottlesExceptions.php

@@ -43,6 +43,13 @@ class ThrottlesExceptions
      */
     protected $retryAfterMinutes = 0;
 
+    /**
+     * The callback that determines if the exception should be reported.
+     *
+     * @var callable
+     */
+    protected $reportCallback;
+
     /**
      * The callback that determines if rate limiting should apply.
      *
@@ -101,6 +108,10 @@ public function handle($job, $next)
                 throw $throwable;
             }
 
+            if ($this->reportCallback && call_user_func($this->reportCallback, $throwable)) {
+                report($throwable);
+            }
+
             $this->limiter->hit($jobKey, $this->decaySeconds);
 
             return $job->release($this->retryAfterMinutes * 60);
@@ -188,6 +199,19 @@ public function byJob()
         return $this;
     }
 
+    /**
+     * Report exceptions and optionally specify a callback that determines if the exception should be reported.
+     *
+     * @param  callable|null  $callback
+     * @return $this
+     */
+    public function report(?callable $callback = null)
+    {
+        $this->reportCallback = $callback ?? fn () => true;
+
+        return $this;
+    }
+
     /**
      * Get the number of seconds that should elapse before the job is retried.
      *

src/Illuminate/Queue/Middleware/ThrottlesExceptionsWithRedis.php

@@ -54,6 +54,10 @@ public function handle($job, $next)
                 throw $throwable;
             }
 
+            if ($this->reportCallback && call_user_func($this->reportCallback, $throwable)) {
+                report($throwable);
+            }
+
             $this->limiter->acquire();
 
             return $job->release($this->retryAfterMinutes * 60);

tests/Integration/Queue/ThrottlesExceptionsTest.php

@@ -5,6 +5,7 @@
 use Exception;
 use Illuminate\Bus\Dispatcher;
 use Illuminate\Bus\Queueable;
+use Illuminate\Contracts\Debug\ExceptionHandler;
 use Illuminate\Contracts\Queue\Job;
 use Illuminate\Queue\CallQueuedHandler;
 use Illuminate\Queue\InteractsWithQueue;
@@ -262,6 +263,36 @@ public function release()
         $this->assertTrue($job->released);
         $this->assertTrue($job->handled);
     }
+
+    public function testReportingExceptions()
+    {
+        $this->spy(ExceptionHandler::class)
+            ->shouldReceive('report')
+            ->twice()
+            ->with(m::type(RuntimeException::class));
+
+        $job = new class
+        {
+            public function release()
+            {
+                return $this;
+            }
+        };
+        $next = function () {
+            throw new RuntimeException('Whoops!');
+        };
+
+        $middleware = new ThrottlesExceptions();
+
+        $middleware->report();
+        $middleware->handle($job, $next);
+
+        $middleware->report(fn () => true);
+        $middleware->handle($job, $next);
+
+        $middleware->report(fn () => false);
+        $middleware->handle($job, $next);
+    }
 }
 
 class CircuitBreakerTestJob

tests/Integration/Queue/ThrottlesExceptionsWithRedisTest.php

@@ -5,6 +5,7 @@
 use Exception;
 use Illuminate\Bus\Dispatcher;
 use Illuminate\Bus\Queueable;
+use Illuminate\Contracts\Debug\ExceptionHandler;
 use Illuminate\Contracts\Queue\Job;
 use Illuminate\Foundation\Testing\Concerns\InteractsWithRedis;
 use Illuminate\Queue\CallQueuedHandler;
@@ -14,6 +15,7 @@
 use Illuminate\Support\Str;
 use Mockery as m;
 use Orchestra\Testbench\TestCase;
+use RuntimeException;
 
 class ThrottlesExceptionsWithRedisTest extends TestCase
 {
@@ -116,6 +118,36 @@ protected function assertJobRanSuccessfully($class, $key)
 
         $this->assertTrue($class::$handled);
     }
+
+    public function testReportingExceptions()
+    {
+        $this->spy(ExceptionHandler::class)
+            ->shouldReceive('report')
+            ->twice()
+            ->with(m::type(RuntimeException::class));
+
+        $job = new class
+        {
+            public function release()
+            {
+                return $this;
+            }
+        };
+        $next = function () {
+            throw new RuntimeException('Whoops!');
+        };
+
+        $middleware = new ThrottlesExceptionsWithRedis();
+
+        $middleware->report();
+        $middleware->handle($job, $next);
+
+        $middleware->report(fn () => true);
+        $middleware->handle($job, $next);
+
+        $middleware->report(fn () => false);
+        $middleware->handle($job, $next);
+    }
 }
 
 class CircuitBreakerWithRedisTestJob