[spiral/queue] Adding RetryPolicyInterceptor

[msmakouz]

Q	A
Bugfix?	❌
Breaks BC?	❌
New feature?	✔️
Issues	#911

What was changed

Added Spiral\Queue\Interceptor\Consume\RetryPolicyInterceptor to enable automatic job retries with a configurable retry policy. To use it, need to add the Spiral\Queue\Attribute\RetryPolicy attribute to the job class:

use Spiral\Queue\Attribute\RetryPolicy;
use Spiral\Queue\JobHandler;

#[RetryPolicy(maxAttempts: 3, delay: 5, multiplier: 2)]
final class Ping extends JobHandler
{
    public function invoke(array $payload): void
    {
        // ...
    }
}

Create an exception that implements interface Spiral\Queue\Exception\RetryableExceptionInterface:

use Spiral\Queue\Exception\RetryableExceptionInterface;
use Spiral\Queue\RetryPolicyInterface;

class RetryException extends \DomainException implements RetryableExceptionInterface
{
    public function isRetryable(): bool
    {
        return true;
    }

    public function getRetryPolicy(): ?RetryPolicyInterface
    {
        return null;
    }
}

The exception must implement the two methods isRetryable and getRetryPolicy. These methods can override the retry behavior and cancel the re-queue- or change the retry policy.

If a RetryException is thrown while a job runs, the job will be re-queued according to the retry policy.

[codecov]

Codecov Report

Patch coverage: 100.00% and project coverage change: +0.06% 🎉

Comparison is base (0c4ba5e) 83.84% compared to head (4e4803a) 83.91%.

❗ Current head 4e4803a differs from pull request most recent head fc3c61c. Consider uploading reports for the commit fc3c61c to get more accurate results

Additional details and impacted files

@@             Coverage Diff              @@
##             master     #980      +/-   ##
============================================
+ Coverage     83.84%   83.91%   +0.06%     
- Complexity     6048     6068      +20     
============================================
  Files           793      796       +3     
  Lines         17046    17099      +53     
============================================
+ Hits          14292    14348      +56     
+ Misses         2754     2751       -3     

Files Changed	Coverage Δ
src/Queue/src/Attribute/RetryPolicy.php	100.00% <100.00%> (ø)
src/Queue/src/Bootloader/QueueBootloader.php	94.20% <100.00%> (+0.08%)	⬆️
...src/Interceptor/Consume/RetryPolicyInterceptor.php	100.00% <100.00%> (ø)
src/Queue/src/RetryPolicy.php	100.00% <100.00%> (ø)

... and 3 files with indirect coverage changes

☔ View full report in Codecov by Sentry.
📢 Have feedback on the report? Share it here.