vendor/shopware/core/Framework/MessageQueue/Subscriber/DeadMessageLoadedSubscriber.php line 19

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Shopware\Core\Framework\MessageQueue\Subscriber;
  5. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityLoadedEvent;
  6. use Shopware\Core\Framework\MessageQueue\DeadMessage\DeadMessageEntity;
  7. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  9. /**
  10.  * @deprecated tag:v6.5.0 - reason:becomes-internal - EventSubscribers will become internal in v6.5.0
  11.  */
  12. class DeadMessageLoadedSubscriber implements EventSubscriberInterface
  13. {
  14.     public static function getSubscribedEvents(): array
  15.     {
  16.         return ['dead_message.loaded' => ['unserialize']];
  17.     }
  19.     public function unserialize(EntityLoadedEvent $event): void
  20.     {
  21.         /** @var DeadMessageEntity $deadMessage */
  22.         foreach ($event->getEntities() as $deadMessage) {
  23.             if ($deadMessage->getSerializedOriginalMessage()) {
  24.                 $deadMessage->setOriginalMessage(unserialize($deadMessage->getSerializedOriginalMessage()));
  25.             }
  26.         }
  27.     }
  28. }