vendor/symfony/doctrine-bridge/Messenger/DoctrineClearEntityManagerWorkerSubscriber.php line 38

Open in your IDE?
  1. <?php
  3. /*
  4. * This file is part of the Symfony package.
  5. *
  6. * (c) Fabien Potencier <fabien@symfony.com>
  7. *
  8. * For the full copyright and license information, please view the LICENSE
  9. * file that was distributed with this source code.
  10. */
  12. namespace Symfony\Bridge\Doctrine\Messenger;
  14. use Doctrine\Persistence\ManagerRegistry;
  15. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  16. use Symfony\Component\Messenger\Event\WorkerMessageFailedEvent;
  17. use Symfony\Component\Messenger\Event\WorkerMessageHandledEvent;
  19. /**
  20. * Clears entity managers between messages being handled to avoid outdated data.
  21. *
  22. * @author Ryan Weaver <ryan@symfonycasts.com>
  23. */
  24. class DoctrineClearEntityManagerWorkerSubscriber implements EventSubscriberInterface
  25. {
  26. private $managerRegistry;
  28. public function __construct(ManagerRegistry $managerRegistry)
  29. {
  30. $this->managerRegistry = $managerRegistry;
  31. }
  33. public function onWorkerMessageHandled()
  34. {
  35. $this->clearEntityManagers();
  36. }
  38. public function onWorkerMessageFailed()
  39. {
  40. $this->clearEntityManagers();
  41. }
  43. public static function getSubscribedEvents()
  44. {
  45. return [
  46. WorkerMessageHandledEvent::class => 'onWorkerMessageHandled',
  47. WorkerMessageFailedEvent::class => 'onWorkerMessageFailed',
  48. ];
  49. }
  51. private function clearEntityManagers()
  52. {
  53. foreach ($this->managerRegistry->getManagers() as $manager) {
  54. $manager->clear();
  55. }
  56. }
  57. }