vendor/enqueue/async-event-dispatcher/DependencyInjection/AsyncEventDispatcherExtension.php line 16

Open in your IDE?
  1. <?php
  3. namespace Enqueue\AsyncEventDispatcher\DependencyInjection;
  5. use Enqueue\AsyncEventDispatcher\AsyncProcessor;
  6. use Enqueue\AsyncEventDispatcher\Commands;
  7. use Symfony\Component\Config\FileLocator;
  8. use Symfony\Component\DependencyInjection\Alias;
  9. use Symfony\Component\DependencyInjection\ContainerBuilder;
  10. use Symfony\Component\DependencyInjection\Extension\Extension;
  11. use Symfony\Component\DependencyInjection\Loader\YamlFileLoader;
  12. use Symfony\Component\DependencyInjection\Reference;
  14. class AsyncEventDispatcherExtension extends Extension
  15. {
  16.     public function load(array $configs, ContainerBuilder $container)
  17.     {
  18.         $config = $this->processConfiguration(new Configuration(), $configs);
  20.         $container->setAlias('enqueue.events.context', new Alias($config['context_service'], true));
  22.         $loader = new YamlFileLoader($container, new FileLocator(__DIR__.'/../Resources/config'));
  23.         $loader->load('services.yml');
  25.         $container->register('enqueue.events.async_processor', AsyncProcessor::class)
  26.             ->addArgument(new Reference('enqueue.events.registry'))
  27.             ->addArgument(new Reference('enqueue.events.event_dispatcher'))
  28.             ->addTag('enqueue.processor', [
  29.                 'command' => Commands::DISPATCH_ASYNC_EVENTS,
  30.                 'queue' => '%enqueue_events_queue%',
  31.                 'prefix_queue' => false,
  32.                 'exclusive' => true,
  33.             ])
  34.             ->addTag('enqueue.transport.processor')
  35.         ;
  36.     }
  37. }