Ratelimit Symfony messenger

messenger.yml

framework:
    messenger:
        transports:
            async:
                dsn: '%env(MESSENGER_TRANSPORT_DSN)%'
                retry_strategy:
                    service: App\Symfony\Messenger\Retry\RateLimitHandlingRetryStrategy

RateLimitHandlingRetryStrategy.php

<?php

declare(strict_types=1);

namespace App\Symfony\Messenger\Retry;

use App\Provider\Exception\RateLimitException;
use Symfony\Component\Messenger\Envelope;
use Symfony\Component\Messenger\Exception\HandlerFailedException;
use Symfony\Component\Messenger\Retry\RetryStrategyInterface;

class RateLimitHandlingRetryStrategy implements RetryStrategyInterface
{
    /**
     * @var RetryStrategyInterface
     */
    private RetryStrategyInterface $retryStrategy;

    public function __construct(RetryStrategyInterface $retryStrategy)
    {
        $this->retryStrategy = $retryStrategy;
    }

    /**
     * @inheritDoc
     */
    public function isRetryable(Envelope $message, \Throwable $throwable = null): bool
    {
        if ($throwable instanceof HandlerFailedException) {
            $nestedException = current($throwable->getNestedExceptions());
            if ($nestedException instanceof RateLimitException) {
                return true;
            }
        }

        return $this->retryStrategy->isRetryable($message, $throwable);
    }

    /**
     * @inheritDoc
     */
    public function getWaitingTime(Envelope $message, \Throwable $throwable = null): int
    {
        if ($throwable instanceof HandlerFailedException) {
            $nestedException = current($throwable->getNestedExceptions());
            if ($nestedException instanceof RateLimitException) {
                return $nestedException->getDelay();
            }
        }

        return $this->retryStrategy->getWaitingTime($message, $throwable);
    }
}

service.yml

services:
   messenger.retry.fallback_retry_strategy:
        class: Symfony\Component\Messenger\Retry\MultiplierRetryStrategy
        arguments:
            $maxRetries: 3
            $delayMilliseconds: 1000
            $multiplier: 1
            $maxDelayMilliseconds: 0

    App\Symfony\Messenger\Retry\RateLimitHandlingRetryStrategy:
        arguments: ['@messenger.retry.fallback_retry_strategy']