Review configuration for messenger

Author: deguif

src/DependencyInjection/Configuration.php

@@ -54,6 +54,12 @@ public function getConfigTreeBuilder()
                     ->info('Defaults to the first index defined')
                 ->end()
                 ->scalarNode('default_manager')->defaultValue('orm')->end()
+                ->arrayNode('messenger')
+                    ->canBeEnabled()
+                    ->children()
+                        ->scalarNode('message_bus')->defaultNull()->end()
+                    ->end()
+                ->end()
                 ->arrayNode('serializer')
                     ->treatNullLike([])
                     ->children()

src/DependencyInjection/FOSElasticaExtension.php

@@ -19,9 +19,11 @@
 use Symfony\Component\DependencyInjection\ChildDefinition;
 use Symfony\Component\DependencyInjection\ContainerAwareInterface;
 use Symfony\Component\DependencyInjection\ContainerBuilder;
+use Symfony\Component\DependencyInjection\Exception\LogicException;
 use Symfony\Component\DependencyInjection\Loader\XmlFileLoader;
 use Symfony\Component\DependencyInjection\Reference;
 use Symfony\Component\HttpKernel\DependencyInjection\Extension;
+use Symfony\Component\Messenger\MessageBusInterface;
 
 class FOSElasticaExtension extends Extension
 {
@@ -80,6 +82,10 @@ public function load(array $configs, ContainerBuilder $container)
             $config['default_index'] = reset($keys);
         }
 
+        if ($this->isConfigEnabled($container, $config['messenger'])) {
+            $this->registerMessengerConfiguration($config['messenger'], $container, $loader);
+        }
+
         if (isset($config['serializer'])) {
             $loader->load('serializer.xml');
 
@@ -739,4 +745,17 @@ private function getClient(string $clientName): Reference
 
         return $this->clients[$clientName]['reference'];
     }
+
+    private function registerMessengerConfiguration(array $config, ContainerBuilder $container, XmlFileLoader $loader): void
+    {
+        if (!interface_exists(MessageBusInterface::class)) {
+            throw new LogicException('Messenger support cannot be enabled as the Messenger component is not installed. Try running "composer require symfony/messenger".');
+        }
+
+        $loader->load('messenger.xml');
+
+        $container->getDefinition('fos_elastica.async_pager_persister')
+            ->replaceArgument(2, $config['message_bus'] ? new Reference($config['message_bus']) : new Reference('messenger.default_bus'))
+        ;
+    }
 }

src/Resources/config/messenger.xml

@@ -0,0 +1,16 @@
+<?xml version="1.0" encoding="UTF-8" ?>
+
+<container xmlns="http://symfony.com/schema/dic/services"
+           xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+           xsi:schemaLocation="http://symfony.com/schema/dic/services http://symfony.com/schema/dic/services/services-1.0.xsd">
+
+    <services>
+        <service id="fos_elastica.async_pager_persister" class="FOS\ElasticaBundle\Persister\AsyncPagerPersister">
+            <argument type="service" id="fos_elastica.pager_persister_registry" />
+            <argument type="service" id="fos_elastica.pager_provider_registry" />
+            <argument /> <!-- message bus-->
+
+            <tag name="fos_elastica.pager_persister" persisterName="async" />
+        </service>
+    </services>
+</container>

src/Resources/config/persister.xml

@@ -12,14 +12,6 @@
             <tag name="fos_elastica.pager_persister" persisterName="in_place" />
         </service>
 
-        <service id="fos_elastica.async_pager_persister" class="FOS\ElasticaBundle\Persister\AsyncPagerPersister">
-            <argument type="service" id="fos_elastica.pager_persister_registry" />
-            <argument type="service" id="fos_elastica.pager_provider_registry" />
-            <argument type="service" id="messenger.default_bus" />
-
-            <tag name="fos_elastica.pager_persister" persisterName="async" />
-        </service>
-
         <service id="fos_elastica.pager_persister_registry" class="FOS\ElasticaBundle\Persister\PagerPersisterRegistry">
             <argument type="tagged_locator" tag="fos_elastica.pager_persister" index-by="persisterName" />
         </service>