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

Add ability to change used context.

Author: makasim

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')

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']])

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: