One Hat Cyber Team

Your IP: 216.73.216.45
Server IP: 185.238.29.86
Server: Linux server2 6.8.12-6-pve #1 SMP PREEMPT_DYNAMIC PMX 6.8.12-6 (2024-12-19T19:05Z) x86_64
Server Software: nginx/1.18.0
PHP Version: 8.1.31
Buat File | Buat Folder

Dir : ~/var/www/shopware/vendor/enqueue/amqp-tools/

View File Name : DelayStrategyTransportFactoryTrait.php

<?php

declare(strict_types=1);

namespace Enqueue\AmqpTools;

use Symfony\Component\DependencyInjection\ContainerBuilder;
use Symfony\Component\DependencyInjection\Reference;

trait DelayStrategyTransportFactoryTrait
{
    public function registerDelayStrategy(ContainerBuilder $container, array $config, string $factoryId, string $factoryName): void
    {
        if ($config['delay_strategy']) {
            $factory = $container->getDefinition($factoryId);

            if (false == (is_a($factory->getClass(), DelayStrategyAware::class, true) || $factory->getFactory())) {
                throw new \LogicException('Connection factory does not support delays');
            }

            if ('dlx' === strtolower($config['delay_strategy'])) {
                $delayId = sprintf('enqueue.client.%s.delay_strategy', $factoryName);
                $container->register($delayId, RabbitMqDlxDelayStrategy::class);

                $factory->addMethodCall('setDelayStrategy', [new Reference($delayId)]);
            } elseif ('delayed_message_plugin' === strtolower($config['delay_strategy'])) {
                $delayId = sprintf('enqueue.client.%s.delay_strategy', $factoryName);
                $container->register($delayId, RabbitMqDelayPluginDelayStrategy::class);

                $factory->addMethodCall('setDelayStrategy', [new Reference($delayId)]);
            } else {
                $factory->addMethodCall('setDelayStrategy', [new Reference($config['delay_strategy'])]);
            }
        }
    }
}