AsyncCommandExtension.php

<?php

namespace Enqueue\AsyncCommand\DependencyInjection;

use Enqueue\AsyncCommand\Commands;
use Enqueue\AsyncCommand\RunCommandProcessor;
use Symfony\Component\DependencyInjection\ContainerBuilder;
use Symfony\Component\DependencyInjection\Extension\Extension;

class AsyncCommandExtension extends Extension
{
    public function load(array $configs, ContainerBuilder $container): void
    {
        foreach ($configs['clients'] as $client) {
            // BC compatibility
            if (!is_array($client)) {
                $client = [
                    'name' => $client,
                    'command_name' => Commands::RUN_COMMAND,
                    'queue_name' => Commands::RUN_COMMAND,
                    'timeout' => 60,
                ];
            }

            $id = sprintf('enqueue.async_command.%s.run_command_processor', $client['name']);
            $container->register($id, RunCommandProcessor::class)
                ->addArgument('%kernel.project_dir%')
                ->addArgument($client['timeout'])
                ->addTag('enqueue.processor', [
                    'client' => $client['name'],
                    'command' => $client['command_name'] ?? Commands::RUN_COMMAND,
                    'queue' => $client['queue_name'] ?? Commands::RUN_COMMAND,
                    'prefix_queue' => false,
                    'exclusive' => true,
                ])
                ->addTag('enqueue.transport.processor')
            ;
        }
    }
}