Use plugin-dedicated messenger command bus

config/config.yaml

@@ -65,6 +65,30 @@ framework:
     messenger:
         routing:
             'Webgriffe\SyliusAkeneoPlugin\Message\ItemImport': main
+
+        buses:
+            webgriffe_sylius_akeneo.command_bus:
+                middleware:
+                    - 'webgriffe_sylius_akeneo.middleware.item_import_result_persister'
+
+                    # each time a message is handled, the Doctrine connection
+                    # is "pinged" and reconnected if it's closed. Useful
+                    # if your workers run for a long time and the database
+                    # connection is sometimes lost
+                    - doctrine_ping_connection
+
+                    # After handling, the Doctrine connection is closed,
+                    # which can free up database connections in a worker,
+                    # instead of keeping them open forever
+                    - doctrine_close_connection
+
+                    # wraps all handlers in a single Doctrine transaction
+                    # handlers do not need to call flush() and an error
+                    # in any handler will cause a rollback
+                    - doctrine_transaction
+
+                    # logs an error when a Doctrine transaction was opened but not closed
+                    - doctrine_open_transaction_logger
 
 monolog:
     channels: ['webgriffe_sylius_akeneo_plugin']

config/services.xml

@@ -10,7 +10,7 @@
         <service id="webgriffe_sylius_akeneo.command.import" class="Webgriffe\SyliusAkeneoPlugin\Command\ImportCommand">
             <argument type="service" id="webgriffe_sylius_akeneo.date_time_builder"/>
             <argument type="service" id="webgriffe_sylius_akeneo.importer_registry"/>
-            <argument type="service" id="messenger.default_bus"/>
+            <argument type="service" id="webgriffe_sylius_akeneo.command_bus"/>
             <tag name="console.command" />
         </service>
 
@@ -54,7 +54,7 @@
         <service id="webgriffe_sylius_akeneo.controller.product_import_controller" class="Webgriffe\SyliusAkeneoPlugin\Controller\ProductImportController" >
             <tag name="controller.service_arguments"/>
             <argument type="service" id="sylius.repository.product" />
-            <argument type="service" id="messenger.default_bus" />
+            <argument type="service" id="webgriffe_sylius_akeneo.command_bus" />
             <argument type="service" id="translator" />
             <call method="setContainer">
                 <argument type="service" id="service_container" />

docs/configuration.md

@@ -25,24 +25,3 @@ webgriffe_sylius_akeneo:
 Pay attention that among these parameters there are some sensitive configuration that you probably don't want to commit
 in your VCS. There are different solutions to this problem, like env configurations and secrets. Refer
 to [Symfony best practices doc](https://symfony.com/doc/current/best_practices.html#configuration) for more info.
-
-To be able to see Akeneo item import results in Sylius backend (see [Usage](usage.md) section) you should enable our dedicated Symfony Messenger middleware for the `sylius.command_bus`.
-To do so you have to add the following configuration in `config/framework.yaml`:
-
-```yaml
-# ...
-
-framework:
-    # ...
-    messenger:
-        # ...
-        sylius.command_bus:
-            middleware:
-                - 'webgriffe_sylius_akeneo.middleware.item_import_result_persister'
-                # The following middlewares should be copied and pasted from sylius.command_bus middlewares defined in
-                # vendor/sylius/sylius/src/Sylius/Bundle/CoreBundle/Resources/config/app/messenger.yaml
-                - 'validation'
-                - 'doctrine_transaction'        
-```
-
-Be aware to put the `webgriffe_sylius_akeneo.middleware.item_import_result_persister` middleware before all other middlewares defined by Sylius core (you should copy and paste them from `vendor/sylius/sylius/src/Sylius/Bundle/CoreBundle/Resources/config/app/messenger.yaml`).

tests/Application/config/packages/framework.yaml

@@ -7,13 +7,3 @@ framework:
     serializer:
         mapping:
             paths: [ '%kernel.project_dir%/config/serialization' ]
-
-    messenger:
-        buses:
-            sylius.command_bus:
-                middleware:
-                    - 'webgriffe_sylius_akeneo.middleware.item_import_result_persister'
-                    # The following middlewares should be copied and pasted from sylius.command_bus middlewares defined in
-                    # vendor/sylius/sylius/src/Sylius/Bundle/CoreBundle/Resources/config/app/messenger.yaml
-                    - 'validation'
-                    - 'doctrine_transaction'