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

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\Log\Package;
  7. use Shopware\Core\Framework\MessageQueue\DeadMessage\DeadMessageEntity;
  8. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  10. /**
  11. * @deprecated tag:v6.5.0 - reason:becomes-internal - EventSubscribers will become internal in v6.5.0
  12. */
  13. #[Package('system-settings')]
  14. class DeadMessageLoadedSubscriber implements EventSubscriberInterface
  15. {
  16. public static function getSubscribedEvents(): array
  17. {
  18. return ['dead_message.loaded' => ['unserialize']];
  19. }
  21. public function unserialize(EntityLoadedEvent $event): void
  22. {
  23. /** @var DeadMessageEntity $deadMessage */
  24. foreach ($event->getEntities() as $deadMessage) {
  25. if ($deadMessage->getSerializedOriginalMessage()) {
  26. $deadMessage->setOriginalMessage(unserialize($deadMessage->getSerializedOriginalMessage()));
  27. }
  28. }
  29. }
  30. }