diff --git a/config/services/registry.yaml b/config/services/registry.yaml index b6c72b9a..d3659ba2 100644 --- a/config/services/registry.yaml +++ b/config/services/registry.yaml @@ -4,4 +4,7 @@ services: autoconfigure: true public: false - Pimcore\Bundle\GenericDataIndexBundle\Repository\IndexQueueRepository: ~ + Pimcore\Bundle\GenericDataIndexBundle\Repository\IndexQueueRepository: + arguments: + - "@doctrine.orm.pimcore_generic_data_index_entity_manager" + diff --git a/src/Repository/IndexQueueRepository.php b/src/Repository/IndexQueueRepository.php index ff68765a..291b72fc 100644 --- a/src/Repository/IndexQueueRepository.php +++ b/src/Repository/IndexQueueRepository.php @@ -14,6 +14,8 @@ namespace Pimcore\Bundle\GenericDataIndexBundle\Repository; use Doctrine\DBAL\Connection; +use Doctrine\ORM\EntityManager; +use Doctrine\ORM\EntityManagerInterface; use Doctrine\ORM\EntityRepository; use Doctrine\ORM\NonUniqueResultException; use Doctrine\ORM\QueryBuilder; @@ -30,15 +32,12 @@ final class IndexQueueRepository { use LoggerAwareTrait; - private readonly ObjectManager $entityManager; - public function __construct( + private readonly EntityManagerInterface $entityManager, private readonly TimeServiceInterface $timeService, private readonly Connection $connection, private readonly DenormalizerInterface $denormalizer, - ManagerRegistry $managerRegistry, ) { - $this->entityManager = $managerRegistry->getManager('pimcore_generic_data_index'); } public function dispatchableItemExists(): bool @@ -166,7 +165,6 @@ private function dispatchItems(int $limit): int private function createQueryBuilder(string $alias): QueryBuilder { - /** @var EntityRepository $repository */ $repository = $this->entityManager->getRepository(IndexQueue::class); return $repository->createQueryBuilder($alias);