vendor/shopware/platform/src/Core/Framework/MessageQueue/Subscriber/MessageFailedHandler.php line 30

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Shopware\Core\Framework\MessageQueue\Subscriber;
  5. use Doctrine\DBAL\Connection;
  6. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  7. use Symfony\Component\Messenger\Envelope;
  8. use Symfony\Component\Messenger\Event\WorkerMessageFailedEvent;
  10. class MessageFailedHandler implements EventSubscriberInterface
  11. {
  12.     /**
  13.      * @var Connection
  14.      */
  15.     private $connection;
  17.     public function __construct(Connection $connection)
  18.     {
  19.         $this->connection = $connection;
  20.     }
  22.     public static function getSubscribedEvents(): array
  23.     {
  24.         return [
  25.             // must have higher priority than SendFailedMessageToFailureTransportListener
  26.             WorkerMessageFailedEvent::class => ['onMessageFailed', 99],
  27.         ];
  28.     }
  30.     public function onMessageFailed(WorkerMessageFailedEvent $event): void
  31.     {
  32.         if ($event->willRetry()) {
  33.             return;
  34.         }
  36.         $this->connection->executeUpdate('
  37.             UPDATE `message_queue_stats`
  38.             SET `size` = `size` - 1
  39.             WHERE `name` = :name;
  40.         ', [
  41.             'name' => $this->getMessageName($event->getEnvelope()),
  42.         ]);
  43.     }
  45.     /**
  46.      * @param object|Envelope $message
  47.      */
  48.     private function getMessageName($message): string
  49.     {
  50.         return $message instanceof Envelope ? \get_class($message->getMessage()) : \get_class($message);
  51.     }
  52. }