platform/src/Core/Framework/MessageQueue/Subscriber/DeadMessageLoadedSubscriber.php line 16

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. class DeadMessageLoadedSubscriber implements EventSubscriberInterface
  10. {
  11.     public static function getSubscribedEvents(): array
  12.     {
  13.         return ['dead_message.loaded' => ['unserialize']];
  14.     }
  16.     public function unserialize(EntityLoadedEvent $event): void
  17.     {
  18.         /** @var DeadMessageEntity $deadMessage */
  19.         foreach ($event->getEntities() as $deadMessage) {
  20.             if ($deadMessage->getSerializedOriginalMessage()) {
  21.                 $deadMessage->setOriginalMessage(unserialize($deadMessage->getSerializedOriginalMessage()));
  22.             }
  23.         }
  24.     }
  25. }