Added: ability to pass entity manager name to use

Author: balabis

pkg/enqueue-bundle/DependencyInjection/Configuration.php

@@ -94,6 +94,9 @@ private function getJobConfiguration(): ArrayNodeDefinition
         }
 
         return (new ArrayNodeDefinition('job'))
+            ->children()
+                ->scalarNode('entity_manager_name')->defaultNull()->end()
+            ->end()
             ->addDefaultsIfNotSet()
             ->canBeEnabled()
         ;

pkg/enqueue-bundle/DependencyInjection/EnqueueExtension.php

@@ -98,6 +98,11 @@ public function load(array $configs, ContainerBuilder $container): void
                     throw new \LogicException('Job-queue supports only default configuration.');
                 }
 
+                $container->setParameter(
+                    'enqueue.job.entity_manager_name',
+                    $modules['job']['entity_manager_name']
+                );
+
                 $loader->load('job.yml');
             }
 

pkg/enqueue-bundle/Resources/config/job.yml

@@ -9,6 +9,7 @@ services:
             - '@doctrine'
             - 'Enqueue\JobQueue\Doctrine\Entity\Job'
             - '%enqueue.job.unique_job_table_name%'
+            - '%enqueue.job.entity_manager_name%'
 
     # Deprecated. To be removed in 0.10.
     enqueue.job.storage:

pkg/job-queue/Doctrine/JobStorage.php

@@ -38,16 +38,23 @@ class JobStorage
      */
     private $uniqueTableName;
 
+    /**
+     * @var string
+     */
+    private $entityManagerName;
+
     /**
      * @param ManagerRegistry $doctrine
-     * @param string          $entityClass
-     * @param string          $uniqueTableName
+     * @param string $entityClass
+     * @param string $uniqueTableName
+     * @param $entityManagerName
      */
-    public function __construct(ManagerRegistry $doctrine, $entityClass, $uniqueTableName)
+    public function __construct(ManagerRegistry $doctrine, $entityClass, $uniqueTableName, $entityManagerName)
     {
         $this->doctrine = $doctrine;
         $this->entityClass = $entityClass;
         $this->uniqueTableName = $uniqueTableName;
+        $this->entityManagerName = $entityManagerName;
     }
 
     /**
@@ -210,7 +217,9 @@ private function getEntityRepository()
     private function getEntityManager()
     {
         if (!$this->em) {
-            $this->em = $this->doctrine->getManagerForClass($this->entityClass);
+            $this->em = empty($this->entityManagerName)
+                ? $this->doctrine->getManagerForClass($this->entityClass)
+                : $this->doctrine->getManager($this->entityManagerName);
         }
         if (!$this->em->isOpen()) {
             $this->em = $this->doctrine->resetManager();