src/WellCommerce/Bundle/AppBundle/EventListener/MessengerQueueSubscriber.php line 48

Open in your IDE?
  1. <?php
  2. declare(strict_types=0);
  3. /*
  4.  * WellCommerce Foundation
  5.  *
  6.  * This file is part of the WellCommerce package.
  7.  *
  8.  * (c) Adam Piotrowski <adam@wellcommerce.org>, Adrian Potepa <adrian@wellcommerce.org>
  9.  *
  10.  * For the full copyright and license information,
  11.  * please view the LICENSE file that was distributed with this source code.
  12.  */
  14. namespace WellCommerce\Bundle\AppBundle\EventListener;
  16. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  17. use Symfony\Component\Messenger\Event\WorkerMessageFailedEvent;
  18. use Symfony\Component\Messenger\Event\WorkerMessageHandledEvent;
  19. use WellCommerce\Bundle\AppBundle\Entity\MessengerQueue;
  20. use WellCommerce\Bundle\CoreBundle\DependencyInjection\AbstractServiceSubscriber;
  21. use WellCommerce\Bundle\CoreBundle\Service\Messenger\MessageInterface;
  23. /**
  24.  * Class AdminSubscriber
  25.  *
  26.  * @author  Adam Piotrowski <adam@wellcommerce.org>
  27.  */
  28. class MessengerQueueSubscriber extends AbstractServiceSubscriber implements EventSubscriberInterface
  29. {
  30.     public static function getSubscribedEvents()
  31.     {
  32.         return [
  33.             WorkerMessageHandledEvent::class => ['onWorkerMessageHandledEvent', 0],
  34.             WorkerMessageFailedEvent::class  => ['onWorkerMessageFailedEvent', 0],
  35.         ];
  36.     }
  38.     public function onWorkerMessageHandledEvent(WorkerMessageHandledEvent $event)
  39.     {
  40.         $env     = $event->getEnvelope();
  41.         $message = $env->getMessage();
  43.         if ($message instanceof MessageInterface) {
  44.             $this->registerMessengerQueue($message);
  45.         }
  46.     }
  48.     public function onWorkerMessageFailedEvent(WorkerMessageFailedEvent $event)
  49.     {
  50.         $env     = $event->getEnvelope();
  51.         $message = $env->getMessage();
  53.         if ($message instanceof MessageInterface) {
  54.             $this->registerMessengerQueue($message, $event->getThrowable());
  55.         }
  56.     }
  58.     protected function registerMessengerQueue(MessageInterface $message, ?\Throwable $throwable = null)
  59.     {
  60.         $queue = new MessengerQueue();
  61.         $queue->setType(get_class($message));
  62.         $queue->setIdentifier($message->getIdentifier());
  63.         $queue->setSuccess(true);
  65.         if ($throwable instanceof \Throwable) {
  66.             $queue->setSuccess(false);
  67.             $queue->setErrorMsg($throwable->getMessage());
  68.         }
  70.         $this->getEntityManager()->persist($queue);
  71.         $this->getEntityManager()->flush();
  72.     }
  74. }