Merge pull request #8 from php-enqueue/add-ability-to-change-queue-co…

…ntext Add ability to change used context.
php-enqueue · Jan 4, 2018 · e2b7252 · e2b7252
2 parents 55c9eaa + 2180513
commit e2b7252
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 3 deletions.
diff --git a/DependencyInjection/Configuration.php b/DependencyInjection/Configuration.php
@@ -16,6 +16,7 @@ public function getConfigTreeBuilder()
         $rootNode = $tb->root('enqueue_elastica');
         $rootNode
             ->children()
+                ->scalarNode('context')->isRequired()->defaultValue('enqueue.transport.context')->cannotBeEmpty()->end()
                 ->arrayNode('doctrine')
                     ->children()
                         ->arrayNode('queue_listeners')

diff --git a/DependencyInjection/EnqueueElasticaExtension.php b/DependencyInjection/EnqueueElasticaExtension.php
@@ -21,6 +21,8 @@ public function load(array $configs, ContainerBuilder $container)
         $loader = new YamlFileLoader($container, new FileLocator(__DIR__.'/../Resources/config'));
         $loader->load('services.yml');
 
+        $container->setAlias('enqueue_elastica.context', $config['context']);
+
         if (false == empty($config['doctrine']['queue_listeners'])) {
             foreach ($config['doctrine']['queue_listeners'] as $listenerConfig) {
                 $listenerId = sprintf(
@@ -31,7 +33,7 @@ public function load(array $configs, ContainerBuilder $container)
 
                 $container->register($listenerId, SyncIndexWithObjectChangeListener::class)
                     ->setPublic(true)
-                    ->addArgument(new Reference('enqueue.transport.context'))
+                    ->addArgument(new Reference('enqueue_elastica.context'))
                     ->addArgument($listenerConfig['model_class'])
                     ->addArgument($listenerConfig)
                     ->addTag('doctrine.event_subscriber', ['connection' => $listenerConfig['connection']])

diff --git a/Resources/config/services.yml b/Resources/config/services.yml
@@ -22,15 +22,15 @@ services:
       class: 'Enqueue\ElasticaBundle\Persister\Listener\PurgePopulateQueueListener'
       public: true
       arguments:
-          - '@enqueue.transport.context'
+          - '@enqueue_elastica.context'
       tags:
           -  { name: 'kernel.event_subscriber' }
 
   enqueue_elastica.queue_pager_perister:
       class: 'Enqueue\ElasticaBundle\Persister\QueuePagerPersister'
       public: true
       arguments:
-          - '@enqueue.transport.context'
+          - '@enqueue_elastica.context'
           - '@fos_elastica.persister_registry'
           - '@event_dispatcher'
       tags: