for testing and deploying your application
for finding and fixing issues
for empowering human code reviews
<?php
declare(strict_types=1);
namespace TMV\Messenger\Factory\Retry;
use function is_string;
use Psr\Container\ContainerInterface;
use Symfony\Component\Messenger\Retry\MultiplierRetryStrategy;
use Symfony\Component\Messenger\Retry\RetryStrategyInterface;
final class RetryStrategyFactory
{
/** @var string */
private $transportName;
public function __construct(string $transportName)
$this->transportName = $transportName;
}
public function __invoke(ContainerInterface $container): RetryStrategyInterface
/** @var array $config */
$config = $container->has('config') ? $container->get('config') : [];
/** @var array|array<string, float|int>|string $retryConfig */
$retryConfig = $config['messenger']['transports'][$this->transportName]['retry_strategy'] ?? [];
if (is_string($retryConfig)) {
is_string($retryConfig)
false
return $container->get($retryConfig);
return new MultiplierRetryStrategy(
(int) ($retryConfig['max_retries'] ?? 3),
(int) ($retryConfig['delay'] ?? 1000),
(float) ($retryConfig['multiplier'] ?? 2.),
(int) ($retryConfig['max_delay'] ?? 0)
);
thomasvargiu /
zf-messenger
Loading history...